diff --git a/Dockerfile b/Dockerfile
index 5d06d6c828..a264ac8795 100755
--- a/Dockerfile
+++ b/Dockerfile
@@ -98,24 +98,9 @@ RUN chmod +x /usr/local/bin/doctor && \
     chmod +x /usr/local/bin/worker-messaging && \
     chmod +x /usr/local/bin/worker-webhooks && \
     chmod +x /usr/local/bin/worker-migrations && \
-    chmod +x /usr/local/bin/worker-hamster && \
     chmod +x /usr/local/bin/worker-usage && \
     chmod +x /usr/local/bin/worker-usage-dump
 
-
-# Cloud Executabless
-RUN chmod +x /usr/local/bin/hamster && \
-    chmod +x /usr/local/bin/volume-sync && \
-    chmod +x /usr/local/bin/patch-delete-schedule-updated-at-attribute && \
-    chmod +x /usr/local/bin/patch-recreate-repositories-documents && \
-    chmod +x /usr/local/bin/patch-delete-project-collections && \
-    chmod +x /usr/local/bin/delete-orphaned-projects && \
-    chmod +x /usr/local/bin/clear-card-cache && \
-    chmod +x /usr/local/bin/calc-users-stats && \
-    chmod +x /usr/local/bin/calc-tier-stats && \
-    chmod +x /usr/local/bin/get-migration-stats && \
-    chmod +x /usr/local/bin/create-inf-metric
-
 # Letsencrypt Permissions
 RUN mkdir -p /etc/letsencrypt/live/ && chmod -Rf 755 /etc/letsencrypt/live/
 
diff --git a/README.md b/README.md
index 62b084d320..88b4173f1d 100644
--- a/README.md
+++ b/README.md
@@ -1,4 +1,4 @@
-> Great news! Appwrite Cloud is now in public beta! Sign up at [cloud.appwrite.io](https://cloud.appwrite.io) for a hassle-free, hosted experience. Join us in the Cloud today! ☁️🎉
+> Our Appwrite Init event has concluded. You can check out all the new and upcoming features [on our Init website](https://appwrite.io/init) 🚀
 
 <br />
 <p align="center">
diff --git a/app/cli.php b/app/cli.php
index d7cc5fe414..4e1df30f9a 100644
--- a/app/cli.php
+++ b/app/cli.php
@@ -131,9 +131,6 @@ CLI::setResource('queue', function (Group $pools) {
 CLI::setResource('queueForFunctions', function (Connection $queue) {
     return new Func($queue);
 }, ['queue']);
-CLI::setResource('queueForHamster', function (Connection $queue) {
-    return new Hamster($queue);
-}, ['queue']);
 CLI::setResource('queueForDeletes', function (Connection $queue) {
     return new Delete($queue);
 }, ['queue']);
diff --git a/app/config/errors.php b/app/config/errors.php
index 1699157d8c..91698e1f78 100644
--- a/app/config/errors.php
+++ b/app/config/errors.php
@@ -639,7 +639,7 @@ return [
     Exception::PROJECT_PROVIDER_UNSUPPORTED => [
         'name' => Exception::PROJECT_PROVIDER_UNSUPPORTED,
         'description' => 'The chosen OAuth provider is unsupported. Please check the <a href="/docs/client/account?sdk=web-default#accountCreateOAuth2Session">Create OAuth2 Session docs</a> for the complete list of supported OAuth providers.',
-        'code' => 501,
+        'code' => 400,
     ],
     Exception::PROJECT_INVALID_SUCCESS_URL => [
         'name' => Exception::PROJECT_INVALID_SUCCESS_URL,
diff --git a/app/controllers/api/health.php b/app/controllers/api/health.php
index d9faf998e6..6a2c1b0bed 100644
--- a/app/controllers/api/health.php
+++ b/app/controllers/api/health.php
@@ -796,12 +796,12 @@ App::get('/v1/health/queue/failed/:name')
         Event::MAILS_QUEUE_NAME,
         Event::FUNCTIONS_QUEUE_NAME,
         Event::USAGE_QUEUE_NAME,
+        Event::USAGE_DUMP_QUEUE_NAME,
         Event::WEBHOOK_CLASS_NAME,
         Event::CERTIFICATES_QUEUE_NAME,
         Event::BUILDS_QUEUE_NAME,
         Event::MESSAGING_QUEUE_NAME,
-        Event::MIGRATIONS_QUEUE_NAME,
-        Event::HAMSTER_CLASS_NAME
+        Event::MIGRATIONS_QUEUE_NAME
     ]), 'The name of the queue')
     ->param('threshold', 5000, new Integer(true), 'Queue size threshold. When hit (equal or higher), endpoint returns server error. Default value is 5000.', true)
     ->label('sdk.description', '/docs/references/health/get-failed-queue-jobs.md')
diff --git a/app/controllers/api/projects.php b/app/controllers/api/projects.php
index 9e08c3774a..0174d59d95 100644
--- a/app/controllers/api/projects.php
+++ b/app/controllers/api/projects.php
@@ -4,6 +4,7 @@ use Appwrite\Auth\Auth;
 use Appwrite\Event\Delete;
 use Appwrite\Event\Validator\Event;
 use Appwrite\Extend\Exception;
+use Appwrite\Hooks\Hooks;
 use Appwrite\Network\Validator\Email;
 use Appwrite\Network\Validator\Origin;
 use Appwrite\Template\Template;
@@ -75,7 +76,8 @@ App::post('/v1/projects')
     ->inject('dbForConsole')
     ->inject('cache')
     ->inject('pools')
-    ->action(function (string $projectId, string $name, string $teamId, string $region, string $description, string $logo, string $url, string $legalName, string $legalCountry, string $legalState, string $legalCity, string $legalAddress, string $legalTaxId, Response $response, Database $dbForConsole, Cache $cache, Group $pools) {
+    ->inject('hooks')
+    ->action(function (string $projectId, string $name, string $teamId, string $region, string $description, string $logo, string $url, string $legalName, string $legalCountry, string $legalState, string $legalCity, string $legalAddress, string $legalTaxId, Response $response, Database $dbForConsole, Cache $cache, Group $pools, Hooks $hooks) {
 
 
         $team = $dbForConsole->getDocument('teams', $teamId);
@@ -217,6 +219,8 @@ App::post('/v1/projects')
             $dbForProject->createCollection($key, $attributes, $indexes);
         }
 
+        $hooks->trigger('afterProjectCreation', [ $project, $pools, $cache ]);
+
         $response
             ->setStatusCode(Response::STATUS_CODE_CREATED)
             ->dynamic($project, Response::MODEL_PROJECT);
diff --git a/app/controllers/general.php b/app/controllers/general.php
index 11fabe7550..01bc946add 100644
--- a/app/controllers/general.php
+++ b/app/controllers/general.php
@@ -167,7 +167,7 @@ function router(App $utopia, Database $dbForConsole, callable $getProjectDB, Swo
 
         $permissions = $function->getAttribute('execute');
 
-        if (!(\in_array('any', $permissions)) && (\in_array('guests', $permissions))) {
+        if (!(\in_array('any', $permissions)) && !(\in_array('guests', $permissions))) {
             throw new AppwriteException(AppwriteException::USER_UNAUTHORIZED, 'To execute function using domain, execute permissions must include "any" or "guests"');
         }
 
@@ -367,6 +367,18 @@ function router(App $utopia, Database $dbForConsole, callable $getProjectDB, Swo
     return false;
 }
 
+/*
+App::init()
+    ->groups(['api'])
+    ->inject('project')
+    ->inject('mode')
+    ->action(function (Document $project, string $mode) {
+        if ($mode === APP_MODE_ADMIN && $project->getId() === 'console') {
+            throw new AppwriteException(AppwriteException::GENERAL_BAD_REQUEST, 'Admin mode is not allowed for console project');
+        }
+    });
+*/
+
 App::init()
     ->groups(['api', 'web'])
     ->inject('utopia')
@@ -630,7 +642,7 @@ App::init()
             : Role::users()->toString();
 
         // Add user roles
-        $memberships = $user->find('teamId', $project->getAttribute('teamId'), 'memberships');
+        $memberships = $user->find('teamInternalId', $project->getAttribute('teamInternalId'), 'memberships');
 
         if ($memberships) {
             foreach ($memberships->getAttribute('roles', []) as $memberRole) {
@@ -820,31 +832,24 @@ App::error()
                 }
                 break;
             case 'Utopia\Database\Exception\Conflict':
-                \var_dump('Wrapping conflict exception');
                 $error = new AppwriteException(AppwriteException::DOCUMENT_UPDATE_CONFLICT, previous: $error);
                 break;
             case 'Utopia\Database\Exception\Timeout':
-                \var_dump('Wrapping timeout exception');
                 $error = new AppwriteException(AppwriteException::DATABASE_TIMEOUT, previous: $error);
                 break;
             case 'Utopia\Database\Exception\Query':
-                \var_dump('Wrapping query exception');
                 $error = new AppwriteException(AppwriteException::GENERAL_QUERY_INVALID, $error->getMessage(), previous: $error);
                 break;
             case 'Utopia\Database\Exception\Structure':
-                \var_dump('Wrapping structure exception');
                 $error = new AppwriteException(AppwriteException::DOCUMENT_INVALID_STRUCTURE, $error->getMessage(), previous: $error);
                 break;
             case 'Utopia\Database\Exception\Duplicate':
-                \var_dump('Wrapping duplicate exception');
                 $error = new AppwriteException(AppwriteException::DOCUMENT_ALREADY_EXISTS);
                 break;
             case 'Utopia\Database\Exception\Restricted':
-                \var_dump('Wrapping restricted exception');
                 $error = new AppwriteException(AppwriteException::DOCUMENT_DELETE_RESTRICTED);
                 break;
             case 'Utopia\Database\Exception\Authorization':
-                \var_dump('Wrapping authorization exception');
                 $error = new AppwriteException(AppwriteException::USER_UNAUTHORIZED);
                 break;
         }
@@ -858,6 +863,7 @@ App::error()
             $publish = $error->getCode() === 0 || $error->getCode() >= 500;
         }
 
+        /*
         if ($error->getCode() >= 400 && $error->getCode() < 500) {
             // Register error logger
             $providerName = App::getEnv('_APP_EXPERIMENT_LOGGING_PROVIDER', '');
@@ -874,6 +880,7 @@ App::error()
                 $publish = true;
             }
         }
+        */
 
         if ($logger && $publish) {
             try {
diff --git a/app/init.php b/app/init.php
index ec7fa7163b..64d7998025 100644
--- a/app/init.php
+++ b/app/init.php
@@ -1266,7 +1266,9 @@ function getDevice($root): Device
             case Storage::DEVICE_S3:
                 return new S3($root, $accessKey, $accessSecret, $bucket, $region, $acl);
             case STORAGE::DEVICE_DO_SPACES:
-                return new DOSpaces($root, $accessKey, $accessSecret, $bucket, $region, $acl);
+                $device = new DOSpaces($root, $accessKey, $accessSecret, $bucket, $region, $acl);
+                $device->setHttpVersion(S3::HTTP_VERSION_1_1);
+                return $device;
             case Storage::DEVICE_BACKBLAZE:
                 return new Backblaze($root, $accessKey, $accessSecret, $bucket, $region, $acl);
             case Storage::DEVICE_LINODE:
@@ -1295,7 +1297,9 @@ function getDevice($root): Device
                 $doSpacesRegion = App::getEnv('_APP_STORAGE_DO_SPACES_REGION', '');
                 $doSpacesBucket = App::getEnv('_APP_STORAGE_DO_SPACES_BUCKET', '');
                 $doSpacesAcl = 'private';
-                return new DOSpaces($root, $doSpacesAccessKey, $doSpacesSecretKey, $doSpacesBucket, $doSpacesRegion, $doSpacesAcl);
+                $device = new DOSpaces($root, $doSpacesAccessKey, $doSpacesSecretKey, $doSpacesBucket, $doSpacesRegion, $doSpacesAcl);
+                $device->setHttpVersion(S3::HTTP_VERSION_1_1);
+                return $device;
             case Storage::DEVICE_BACKBLAZE:
                 $backblazeAccessKey = App::getEnv('_APP_STORAGE_BACKBLAZE_ACCESS_KEY', '');
                 $backblazeSecretKey = App::getEnv('_APP_STORAGE_BACKBLAZE_SECRET', '');
diff --git a/app/realtime.php b/app/realtime.php
index f7fc7070a4..9c6ae850e4 100644
--- a/app/realtime.php
+++ b/app/realtime.php
@@ -36,74 +36,83 @@ require_once __DIR__ . '/init.php';
 
 Runtime::enableCoroutine(SWOOLE_HOOK_ALL);
 
-function getConsoleDB(): Database
-{
-    global $register;
+// Allows overriding
+if (!function_exists("getConsoleDB")) {
+    function getConsoleDB(): Database
+    {
+        global $register;
 
-    /** @var \Utopia\Pools\Group $pools */
-    $pools = $register->get('pools');
+        /** @var \Utopia\Pools\Group $pools */
+        $pools = $register->get('pools');
 
-    $dbAdapter = $pools
-        ->get('console')
-        ->pop()
-        ->getResource()
-    ;
-
-    $database = new Database($dbAdapter, getCache());
-
-    $database
-        ->setNamespace('_console')
-        ->setMetadata('host', \gethostname())
-        ->setMetadata('project', '_console');
-
-    return $database;
-}
-
-function getProjectDB(Document $project): Database
-{
-    global $register;
-
-    /** @var \Utopia\Pools\Group $pools */
-    $pools = $register->get('pools');
-
-    if ($project->isEmpty() || $project->getId() === 'console') {
-        return getConsoleDB();
-    }
-
-    $dbAdapter = $pools
-        ->get($project->getAttribute('database'))
-        ->pop()
-        ->getResource()
-    ;
-
-    $database = new Database($dbAdapter, getCache());
-
-    $database
-        ->setNamespace('_' . $project->getInternalId())
-        ->setMetadata('host', \gethostname())
-        ->setMetadata('project', $project->getId());
-
-    return $database;
-}
-
-function getCache(): Cache
-{
-    global $register;
-
-    $pools = $register->get('pools'); /** @var \Utopia\Pools\Group $pools */
-
-    $list = Config::getParam('pools-cache', []);
-    $adapters = [];
-
-    foreach ($list as $value) {
-        $adapters[] = $pools
-            ->get($value)
+        $dbAdapter = $pools
+            ->get('console')
             ->pop()
             ->getResource()
         ;
-    }
 
-    return new Cache(new Sharding($adapters));
+        $database = new Database($dbAdapter, getCache());
+
+        $database
+            ->setNamespace('_console')
+            ->setMetadata('host', \gethostname())
+            ->setMetadata('project', '_console');
+
+        return $database;
+    }
+}
+
+// Allows overriding
+if (!function_exists("getProjectDB")) {
+    function getProjectDB(Document $project): Database
+    {
+        global $register;
+
+        /** @var \Utopia\Pools\Group $pools */
+        $pools = $register->get('pools');
+
+        if ($project->isEmpty() || $project->getId() === 'console') {
+            return getConsoleDB();
+        }
+
+        $dbAdapter = $pools
+            ->get($project->getAttribute('database'))
+            ->pop()
+            ->getResource()
+        ;
+
+        $database = new Database($dbAdapter, getCache());
+
+        $database
+            ->setNamespace('_' . $project->getInternalId())
+            ->setMetadata('host', \gethostname())
+            ->setMetadata('project', $project->getId());
+
+        return $database;
+    }
+}
+
+// Allows overriding
+if (!function_exists("getCache")) {
+    function getCache(): Cache
+    {
+        global $register;
+
+        $pools = $register->get('pools'); /** @var \Utopia\Pools\Group $pools */
+
+        $list = Config::getParam('pools-cache', []);
+        $adapters = [];
+
+        foreach ($list as $value) {
+            $adapters[] = $pools
+                ->get($value)
+                ->pop()
+                ->getResource()
+            ;
+        }
+
+        return new Cache(new Sharding($adapters));
+    }
 }
 
 $realtime = new Realtime();
@@ -204,29 +213,29 @@ $server->onStart(function () use ($stats, $register, $containerId, &$statsDocume
     /**
      * Save current connections to the Database every 5 seconds.
      */
-    Timer::tick(5000, function () use ($register, $stats, &$statsDocument, $logError) {
-        $payload = [];
-        foreach ($stats as $projectId => $value) {
-            $payload[$projectId] = $stats->get($projectId, 'connectionsTotal');
-        }
-        if (empty($payload) || empty($statsDocument)) {
-            return;
-        }
+    // Timer::tick(5000, function () use ($register, $stats, &$statsDocument, $logError) {
+    //     $payload = [];
+    //     foreach ($stats as $projectId => $value) {
+    //         $payload[$projectId] = $stats->get($projectId, 'connectionsTotal');
+    //     }
+    //     if (empty($payload) || empty($statsDocument)) {
+    //         return;
+    //     }
 
-        try {
-            $database = getConsoleDB();
+    //     try {
+    //         $database = getConsoleDB();
 
-            $statsDocument
-                ->setAttribute('timestamp', DateTime::now())
-                ->setAttribute('value', json_encode($payload));
+    //         $statsDocument
+    //             ->setAttribute('timestamp', DateTime::now())
+    //             ->setAttribute('value', json_encode($payload));
 
-            Authorization::skip(fn () => $database->updateDocument('realtime', $statsDocument->getId(), $statsDocument));
-        } catch (Throwable $th) {
-            call_user_func($logError, $th, "updateWorkerDocument");
-        } finally {
-            $register->get('pools')->reclaim();
-        }
-    });
+    //         Authorization::skip(fn () => $database->updateDocument('realtime', $statsDocument->getId(), $statsDocument));
+    //     } catch (Throwable $th) {
+    //         call_user_func($logError, $th, "updateWorkerDocument");
+    //     } finally {
+    //         $register->get('pools')->reclaim();
+    //     }
+    // });
 });
 
 $server->onWorkerStart(function (int $workerId) use ($server, $register, $stats, $realtime, $logError) {
diff --git a/app/views/general/error.phtml b/app/views/general/error.phtml
index 450dcf8973..a3715e0156 100644
--- a/app/views/general/error.phtml
+++ b/app/views/general/error.phtml
@@ -59,7 +59,7 @@ $title = $this->getParam('title', '')
     <link rel="stylesheet" href="/fonts/main.css" />
     <meta name="viewport" content="width=device-width, initial-scale=1" />
     <meta http-equiv="content-security-policy" content="">
-    <title><?php echo $this->print($title, self::FILTER_ESCAPE); ?></title>
+    <title><?php echo $this->print($title); ?></title>
 
     <style>
         @media(min-width:768px) {
@@ -74,11 +74,11 @@ $title = $this->getParam('title', '')
     <div class="container u-margin-block-start-24">
         <article class="card u-padding-16">
             <div class="u-flex u-flex-vertical u-gap-16">
-                <h1 class="heading-level-4 u-trim-1">Error <?php echo $this->print($code, self::FILTER_ESCAPE); ?></h1>
-                <p class="text"><?php echo $this->print($message, self::FILTER_ESCAPE); ?></p>
+                <h1 class="heading-level-4 u-trim-1">Error <?php echo $this->print($code); ?></h1>
+                <p class="text"><?php echo $this->print($message); ?></p>
                 <div class="u-flex u-flex-vertical u-gap-8">
                     <p class="text">Type</p>
-                    <p><code class="inline-code"><?php echo $this->print($type, self::FILTER_ESCAPE); ?></code></p>
+                    <p><code class="inline-code"><?php echo $this->print($type); ?></code></p>
                 </div>
                 <?php if ($development) : ?>
                     <h2 class="heading-level-5 u-trim-1">Error Trace</h2>
@@ -111,45 +111,6 @@ $title = $this->getParam('title', '')
             </div>
         </article>
     </div>
-    <!--section>
-        <h1>Error <?php echo $this->print($code, self::FILTER_ESCAPE); ?></h1>
-
-        <p><?php echo $this->print($message, self::FILTER_ESCAPE); ?></p>
-
-        <small>Error ID: <?php echo $this->print($errorID, self::FILTER_ESCAPE); ?></small>
-
-        <?php if (!empty($projectURL)) : ?>
-            <hr />
-
-            <p><a href="<?php echo $this->print($projectURL, self::FILTER_ESCAPE); ?>" rel="noopener">Back to <?php echo $this->print($projectName, self::FILTER_ESCAPE); ?></a></p>
-        <?php endif; ?>
-
-        <?php if ($development) : ?>
-            <div>
-
-                <h2>Error Trace</h2>
-
-                <?php foreach ($trace as $log) : ?>
-                    <table>
-                        <?php foreach ($log as $key => $value) : ?>
-                            <tr>
-                                <td style="width: 120px"><?php echo $this->print($key, self::FILTER_ESCAPE); ?></td>
-                                <td>
-                                    <?php if (is_array($value)) : ?>
-                                        <?php echo $this->print(var_export($value, true), self::FILTER_ESCAPE); ?>
-                                    <?php else : ?>
-                                        <?php echo $this->print($value, self::FILTER_ESCAPE); ?>
-                                    <?php endif; ?>
-                                </td>
-                            </tr>
-
-                        <?php endforeach; ?>
-                    </table>
-                <?php endforeach; ?>
-            </div>
-        <?php endif; ?>
-
-    </section-->
     <script type="text/javascript">
         const app = (JSON.parse(localStorage.getItem('appwrite')) ?? {});
         const theme = app.theme ?? 'auto';
diff --git a/app/worker.php b/app/worker.php
index de12bba6cb..32ce35e033 100644
--- a/app/worker.php
+++ b/app/worker.php
@@ -183,9 +183,6 @@ Server::setResource('queueForCertificates', function (Connection $queue) {
 Server::setResource('queueForMigrations', function (Connection $queue) {
     return new Migration($queue);
 }, ['queue']);
-Server::setResource('queueForHamster', function (Connection $queue) {
-    return new Hamster($queue);
-}, ['queue']);
 Server::setResource('logger', function (Registry $register) {
     return $register->get('logger');
 }, ['register']);
diff --git a/bin/calc-tier-stats b/bin/calc-tier-stats
deleted file mode 100644
index c7fb71e6fd..0000000000
--- a/bin/calc-tier-stats
+++ /dev/null
@@ -1,3 +0,0 @@
-#!/bin/sh
-
-php /usr/src/code/app/cli.php calc-tier-stats $@
\ No newline at end of file
diff --git a/bin/calc-users-stats b/bin/calc-users-stats
deleted file mode 100644
index 60472ed7a2..0000000000
--- a/bin/calc-users-stats
+++ /dev/null
@@ -1,3 +0,0 @@
-#!/bin/sh
-
-php /usr/src/code/app/cli.php calc-users-stats $@
\ No newline at end of file
diff --git a/bin/clear-card-cache b/bin/clear-card-cache
deleted file mode 100644
index b39bc13651..0000000000
--- a/bin/clear-card-cache
+++ /dev/null
@@ -1,3 +0,0 @@
-#!/bin/sh
-
-php /usr/src/code/app/cli.php clear-card-cache $@
\ No newline at end of file
diff --git a/bin/create-inf-metric b/bin/create-inf-metric
deleted file mode 100644
index ea7b2b4da0..0000000000
--- a/bin/create-inf-metric
+++ /dev/null
@@ -1,3 +0,0 @@
-#!/bin/sh
-
-php /usr/src/code/app/cli.php create-inf-metric $@
\ No newline at end of file
diff --git a/bin/delete-orphaned-projects b/bin/delete-orphaned-projects
deleted file mode 100644
index 16b9e3184d..0000000000
--- a/bin/delete-orphaned-projects
+++ /dev/null
@@ -1,3 +0,0 @@
-#!/bin/sh
-
-php /usr/src/code/app/cli.php delete-orphaned-projects $@
\ No newline at end of file
diff --git a/bin/get-migration-stats b/bin/get-migration-stats
deleted file mode 100644
index efc1934e15..0000000000
--- a/bin/get-migration-stats
+++ /dev/null
@@ -1,3 +0,0 @@
-#!/bin/sh
-
-php /usr/src/code/app/cli.php get-migration-stats $@
\ No newline at end of file
diff --git a/bin/hamster b/bin/hamster
deleted file mode 100644
index dcc7ed308d..0000000000
--- a/bin/hamster
+++ /dev/null
@@ -1,3 +0,0 @@
-#!/bin/sh
-
-php /usr/src/code/app/cli.php hamster $@
\ No newline at end of file
diff --git a/bin/patch-delete-project-collections b/bin/patch-delete-project-collections
deleted file mode 100644
index 8bf0736cf3..0000000000
--- a/bin/patch-delete-project-collections
+++ /dev/null
@@ -1,3 +0,0 @@
-#!/bin/sh
-
-php /usr/src/code/app/cli.php patch-delete-project-collections $@
\ No newline at end of file
diff --git a/bin/patch-delete-schedule-updated-at-attribute b/bin/patch-delete-schedule-updated-at-attribute
deleted file mode 100644
index 3e28289cbe..0000000000
--- a/bin/patch-delete-schedule-updated-at-attribute
+++ /dev/null
@@ -1,3 +0,0 @@
-#!/bin/sh
-
-php /usr/src/code/app/cli.php patch-delete-schedule-updated-at-attribute $@
\ No newline at end of file
diff --git a/bin/patch-recreate-repositories-documents b/bin/patch-recreate-repositories-documents
deleted file mode 100644
index 8c6c4157f4..0000000000
--- a/bin/patch-recreate-repositories-documents
+++ /dev/null
@@ -1,3 +0,0 @@
-#!/bin/sh
-
-php /usr/src/code/app/cli.php patch-recreate-repositories-documents $@
\ No newline at end of file
diff --git a/bin/volume-sync b/bin/volume-sync
deleted file mode 100644
index 5190750a24..0000000000
--- a/bin/volume-sync
+++ /dev/null
@@ -1,3 +0,0 @@
-#!/bin/sh
-
-php /usr/src/code/app/cli.php volume-sync $@
\ No newline at end of file
diff --git a/bin/worker-hamster b/bin/worker-hamster
deleted file mode 100644
index b388dd13c9..0000000000
--- a/bin/worker-hamster
+++ /dev/null
@@ -1,3 +0,0 @@
-#!/bin/sh
-
-php /usr/src/code/app/worker.php hamster $@
\ No newline at end of file
diff --git a/composer.json b/composer.json
index eaa6cfa206..b51f720aed 100644
--- a/composer.json
+++ b/composer.json
@@ -50,7 +50,7 @@
         "utopia-php/cache": "0.9.*",
         "utopia-php/cli": "0.15.*",
         "utopia-php/config": "0.2.*",
-        "utopia-php/database": "0.45.7",
+        "utopia-php/database": "0.45.14",
         "utopia-php/domains": "0.5.*",
         "utopia-php/dsn": "0.1.*",
         "utopia-php/framework": "0.33.*",
@@ -62,7 +62,7 @@
         "utopia-php/migration": "0.3.*",
         "utopia-php/orchestration": "0.9.*",
         "utopia-php/platform": "0.5.*",
-        "utopia-php/pools": "0.4.*",
+        "utopia-php/pools": "0.5.*",
         "utopia-php/preloader": "0.2.*",
         "utopia-php/queue": "0.7.*",
         "utopia-php/registry": "0.5.*",
diff --git a/docker-compose.yml b/docker-compose.yml
index 26c5301526..4b0f88afb6 100644
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -53,7 +53,7 @@ services:
         DEBUG: false
         TESTING: true
         VERSION: dev
-    ports:
+    ports: 
       - 9501:80
     networks:
       - appwrite
@@ -746,69 +746,12 @@ services:
     environment:
       - _APP_ASSISTANT_OPENAI_API_KEY
 
-  appwrite-worker-hamster:
-    entrypoint: worker-hamster
-    <<: *x-logging
-    container_name: appwrite-worker-hamster
-    image: appwrite-dev
-    networks:
-      - appwrite
-    volumes:
-      - ./app:/usr/src/code/app
-      - ./src:/usr/src/code/src
-    depends_on:
-      - redis
-      - mariadb
-    environment:
-      - _APP_ENV
-      - _APP_WORKER_PER_CORE
-      - _APP_OPENSSL_KEY_V1
-      - _APP_DB_HOST
-      - _APP_DB_PORT
-      - _APP_DB_SCHEMA
-      - _APP_DB_USER
-      - _APP_DB_PASS
-      - _APP_REDIS_HOST
-      - _APP_REDIS_PORT
-      - _APP_REDIS_USER
-      - _APP_REDIS_PASS
-      - _APP_MIXPANEL_TOKEN
-
-  appwrite-hamster-scheduler:
-    entrypoint: hamster
-    <<: *x-logging
-    container_name: appwrite-hamster-scheduler
-    image: appwrite-dev
-    networks:
-      - appwrite
-    volumes:
-      - ./app:/usr/src/code/app
-      - ./src:/usr/src/code/src
-    depends_on:
-      - redis
-      - mariadb
-    environment:
-      - _APP_ENV
-      - _APP_WORKER_PER_CORE
-      - _APP_OPENSSL_KEY_V1
-      - _APP_REDIS_HOST
-      - _APP_REDIS_PORT
-      - _APP_REDIS_USER
-      - _APP_REDIS_PASS
-      - _APP_DB_HOST
-      - _APP_DB_PORT
-      - _APP_DB_SCHEMA
-      - _APP_DB_USER
-      - _APP_DB_PASS
-      - _APP_HAMSTER_TIME
-      - _APP_HAMSTER_INTERVAL
-
   openruntimes-executor:
     container_name: openruntimes-executor
     hostname: appwrite-executor
     <<: *x-logging
     stop_signal: SIGINT
-    image: openruntimes/executor:0.4.5
+    image: openruntimes/executor:0.5.1
     restart: unless-stopped
     networks:
       - appwrite
diff --git a/src/Appwrite/Event/Event.php b/src/Appwrite/Event/Event.php
index 9f71ef5ebc..ecf4d182a1 100644
--- a/src/Appwrite/Event/Event.php
+++ b/src/Appwrite/Event/Event.php
@@ -45,9 +45,6 @@ class Event
     public const MIGRATIONS_QUEUE_NAME = 'v1-migrations';
     public const MIGRATIONS_CLASS_NAME = 'MigrationsV1';
 
-    public const HAMSTER_QUEUE_NAME = 'v1-hamster';
-    public const HAMSTER_CLASS_NAME = 'HamsterV1';
-
     protected string $queue = '';
     protected string $class = '';
     protected string $event = '';
diff --git a/src/Appwrite/Event/Hamster.php b/src/Appwrite/Event/Hamster.php
deleted file mode 100644
index 5d79fce568..0000000000
--- a/src/Appwrite/Event/Hamster.php
+++ /dev/null
@@ -1,157 +0,0 @@
-<?php
-
-namespace Appwrite\Event;
-
-use Utopia\Database\Document;
-use Utopia\Queue\Client;
-use Utopia\Queue\Connection;
-
-class Hamster extends Event
-{
-    protected string $type = '';
-    protected ?Document $project = null;
-    protected ?Document $organization = null;
-    protected ?Document $user = null;
-
-    public const TYPE_PROJECT = 'project';
-    public const TYPE_ORGANISATION = 'organisation';
-    public const TYPE_USER = 'user';
-
-    public function __construct(protected Connection $connection)
-    {
-        parent::__construct($connection);
-
-        $this
-            ->setQueue(Event::HAMSTER_QUEUE_NAME)
-            ->setClass(Event::HAMSTER_CLASS_NAME);
-    }
-
-    /**
-     * Sets the type for the hamster event.
-     *
-     * @param string $type
-     * @return self
-     */
-    public function setType(string $type): self
-    {
-        $this->type = $type;
-
-        return $this;
-    }
-
-    /**
-     * Returns the set type for the hamster event.
-     *
-     * @return string
-     */
-    public function getType(): string
-    {
-        return $this->type;
-    }
-
-    /**
-     * Sets the project for the hamster event.
-     *
-     * @param Document $project
-     */
-    public function setProject(Document $project): self
-    {
-        $this->project = $project;
-
-        return $this;
-    }
-
-    /**
-     * Returns the set project for the hamster event.
-     *
-     * @return Document
-     */
-    public function getProject(): Document
-    {
-        return $this->project;
-    }
-
-    /**
-     * Sets the organization for the hamster event.
-     *
-     * @param Document $organization
-     */
-    public function setOrganization(Document $organization): self
-    {
-        $this->organization = $organization;
-
-        return $this;
-    }
-
-    /**
-     * Returns the set organization for the hamster event.
-     *
-     * @return string
-     */
-    public function getOrganization(): Document
-    {
-        return $this->organization;
-    }
-
-    /**
-     * Sets the user for the hamster event.
-     *
-     * @param Document $user
-     */
-    public function setUser(Document $user): self
-    {
-        $this->user = $user;
-
-        return $this;
-    }
-
-    /**
-     * Returns the set user for the hamster event.
-     *
-     * @return Document
-     */
-    public function getUser(): Document
-    {
-        return $this->user;
-    }
-
-    /**
-     * Executes the function event and sends it to the functions worker.
-     *
-     * @return string|bool
-     * @throws \InvalidArgumentException
-     */
-    public function trigger(): string|bool
-    {
-        if ($this->paused) {
-            return false;
-        }
-
-        $client = new Client($this->queue, $this->connection);
-
-        $events = $this->getEvent() ? Event::generateEvents($this->getEvent(), $this->getParams()) : null;
-
-        return $client->enqueue([
-            'type' => $this->type,
-            'project' => $this->project,
-            'organization' => $this->organization,
-            'user' => $this->user,
-            'events' => $events,
-        ]);
-    }
-
-    /**
-     * Generate a function event from a base event
-     *
-     * @param Event $event
-     *
-     * @return self
-     *
-     */
-    public function from(Event $event): self
-    {
-        $this->event = $event->getEvent();
-        $this->params = $event->getParams();
-        return $this;
-    }
-}
diff --git a/src/Appwrite/Hooks/Hooks.php b/src/Appwrite/Hooks/Hooks.php
index 00d2f5a9e9..4840229086 100644
--- a/src/Appwrite/Hooks/Hooks.php
+++ b/src/Appwrite/Hooks/Hooks.php
@@ -16,11 +16,14 @@ class Hooks
 
     /**
      * @param mixed[] $params
+     * @return mixed
      */
-    public function trigger(string $name, array $params = [])
+    public function trigger(string $name, array $params = []): mixed
     {
         if (isset(self::$hooks[$name])) {
-            call_user_func_array(self::$hooks[$name], $params);
+            return call_user_func_array(self::$hooks[$name], $params);
         }
+
+        return null;
     }
 }
diff --git a/src/Appwrite/Platform/Services/Tasks.php b/src/Appwrite/Platform/Services/Tasks.php
index eb06c425c0..8a6890f630 100644
--- a/src/Appwrite/Platform/Services/Tasks.php
+++ b/src/Appwrite/Platform/Services/Tasks.php
@@ -11,17 +11,10 @@ use Appwrite\Platform\Tasks\Schedule;
 use Appwrite\Platform\Tasks\SDKs;
 use Appwrite\Platform\Tasks\Specs;
 use Appwrite\Platform\Tasks\SSL;
-use Appwrite\Platform\Tasks\Hamster;
 use Appwrite\Platform\Tasks\Vars;
 use Appwrite\Platform\Tasks\Version;
-use Appwrite\Platform\Tasks\VolumeSync;
-use Appwrite\Platform\Tasks\CalcTierStats;
 use Appwrite\Platform\Tasks\Upgrade;
-use Appwrite\Platform\Tasks\DeleteOrphanedProjects;
-use Appwrite\Platform\Tasks\GetMigrationStats;
-use Appwrite\Platform\Tasks\PatchRecreateRepositoriesDocuments;
 use Appwrite\Platform\Tasks\QueueRetry;
-use Appwrite\Platform\Tasks\CreateInfMetric;
 use Appwrite\Platform\Tasks\QueueCount;
 
 class Tasks extends Service
@@ -33,7 +26,6 @@ class Tasks extends Service
             ->addAction(Version::getName(), new Version())
             ->addAction(Vars::getName(), new Vars())
             ->addAction(SSL::getName(), new SSL())
-            ->addAction(Hamster::getName(), new Hamster())
             ->addAction(Doctor::getName(), new Doctor())
             ->addAction(Install::getName(), new Install())
             ->addAction(Upgrade::getName(), new Upgrade())
@@ -41,15 +33,9 @@ class Tasks extends Service
             ->addAction(Schedule::getName(), new Schedule())
             ->addAction(Migrate::getName(), new Migrate())
             ->addAction(SDKs::getName(), new SDKs())
-            ->addAction(VolumeSync::getName(), new VolumeSync())
             ->addAction(Specs::getName(), new Specs())
-            ->addAction(CalcTierStats::getName(), new CalcTierStats())
-            ->addAction(DeleteOrphanedProjects::getName(), new DeleteOrphanedProjects())
-            ->addAction(PatchRecreateRepositoriesDocuments::getName(), new PatchRecreateRepositoriesDocuments())
-            ->addAction(GetMigrationStats::getName(), new GetMigrationStats())
             ->addAction(QueueRetry::getName(), new QueueRetry())
             ->addAction(QueueCount::getName(), new QueueCount())
-            ->addAction(CreateInfMetric::getName(), new CreateInfMetric())
         ;
     }
 }
diff --git a/src/Appwrite/Platform/Services/Workers.php b/src/Appwrite/Platform/Services/Workers.php
index 22e6dcd56a..fb6eae7757 100644
--- a/src/Appwrite/Platform/Services/Workers.php
+++ b/src/Appwrite/Platform/Services/Workers.php
@@ -12,7 +12,6 @@ use Appwrite\Platform\Workers\Databases;
 use Appwrite\Platform\Workers\Functions;
 use Appwrite\Platform\Workers\Builds;
 use Appwrite\Platform\Workers\Deletes;
-use Appwrite\Platform\Workers\Hamster;
 use Appwrite\Platform\Workers\Usage;
 use Appwrite\Platform\Workers\UsageDump;
 use Appwrite\Platform\Workers\Migrations;
@@ -32,7 +31,6 @@ class Workers extends Service
             ->addAction(Functions::getName(), new Functions())
             ->addAction(Builds::getName(), new Builds())
             ->addAction(Deletes::getName(), new Deletes())
-            ->addAction(Hamster::getName(), new Hamster())
             ->addAction(UsageDump::getName(), new UsageDump())
             ->addAction(Usage::getName(), new Usage())
             ->addAction(Migrations::getName(), new Migrations())
diff --git a/src/Appwrite/Platform/Tasks/CalcTierStats.php b/src/Appwrite/Platform/Tasks/CalcTierStats.php
deleted file mode 100644
index 2c904973a9..0000000000
--- a/src/Appwrite/Platform/Tasks/CalcTierStats.php
+++ /dev/null
@@ -1,409 +0,0 @@
-<?php
-
-namespace Appwrite\Platform\Tasks;
-
-use Exception;
-use League\Csv\CannotInsertRecord;
-use Utopia\App;
-use Utopia\Database\Document;
-use Utopia\Database\Validator\Authorization;
-use Utopia\Platform\Action;
-use Utopia\Cache\Cache;
-use Utopia\CLI\Console;
-use Utopia\Database\Database;
-use Utopia\Database\Query;
-use League\Csv\Writer;
-use PHPMailer\PHPMailer\PHPMailer;
-use Utopia\Pools\Group;
-use Utopia\Registry\Registry;
-use Utopia\Validator\Text;
-
-class CalcTierStats extends Action
-{
-    /*
-     * Csv cols headers
-     */
-    private array $columns = [
-        'Project ID',
-        'Organization ID',
-        'Organization Email',
-        'Organization Members',
-        'Teams',
-        'Users',
-        'Requests',
-        'Bandwidth',
-        'Domains',
-        'Api keys',
-        'Webhooks',
-        'Platforms',
-        'Buckets',
-        'Files',
-        'Storage (bytes)',
-        'Max File Size (bytes)',
-        'Databases',
-        'Functions',
-        'Deployments',
-        'Executions',
-        'Migrations',
-    ];
-
-    protected string $directory = '/usr/local';
-    protected string $path;
-    protected string $date;
-
-    private array $usageStats = [
-        'network.requests'  => 'Requests',
-        'network.inbound'   => 'Inbound',
-        'network.outbound'  => 'Outbound',
-
-    ];
-
-    public static function getName(): string
-    {
-        return 'calc-tier-stats';
-    }
-
-    public function __construct()
-    {
-
-        $this
-            ->desc('Get stats for projects')
-            ->param('after', '', new Text(36), 'After cursor', true)
-            ->param('projectId', '', new Text(36), 'Select project to validate', true)
-            ->inject('pools')
-            ->inject('cache')
-            ->inject('dbForConsole')
-            ->inject('getProjectDB')
-            ->inject('register')
-            ->callback(function ($after, $projectId, Group $pools, Cache $cache, Database $dbForConsole, callable $getProjectDB, Registry $register) {
-                $this->action($after, $projectId, $pools, $cache, $dbForConsole, $getProjectDB, $register);
-            });
-    }
-
-
-    public function action(string $after, string $projectId, Group $pools, Cache $cache, Database $dbForConsole, callable $getProjectDB, Registry $register): void
-    {
-        //docker compose exec -t appwrite calc-tier-stats
-
-        Console::title('Cloud free tier  stats calculation V1');
-        Console::success(APP_NAME . ' cloud free tier  stats calculation has started');
-
-        /** CSV stuff */
-        $this->date = date('Y-m-d');
-        $this->path = "{$this->directory}/tier_stats_{$this->date}.csv";
-        $csv = Writer::createFromPath($this->path, 'w');
-        $csv->insertOne($this->columns);
-
-        if (!empty($projectId)) {
-            try {
-                console::log("Project " . $projectId);
-                $project = $dbForConsole->getDocument('projects', $projectId);
-                $dbForProject = call_user_func($getProjectDB, $project);
-                $data = $this->getData($project, $dbForConsole, $dbForProject);
-                $csv->insertOne($data);
-                $this->sendMail($register);
-
-                return;
-            } catch (\Throwable $th) {
-                Console::error("Unexpected error occured with Project ID {$projectId}");
-                Console::error('[Error] Type: ' . get_class($th));
-                Console::error('[Error] Message: ' . $th->getMessage());
-                Console::error('[Error] File: ' . $th->getFile());
-                Console::error('[Error] Line: ' . $th->getLine());
-            }
-        }
-
-        $queries = [];
-
-        if (!empty($after)) {
-            Console::info("Iterating remaining projects after project with ID {$after}");
-            $project = $dbForConsole->getDocument('projects', $after);
-            $queries = [Query::cursorAfter($project)];
-        } else {
-            Console::info("Iterating all projects");
-        }
-
-        $this->foreachDocument($dbForConsole, 'projects', $queries, function (Document $project) use ($getProjectDB, $dbForConsole, $csv) {
-            $projectId = $project->getId();
-            console::log("Project " . $projectId);
-            try {
-                $dbForProject = call_user_func($getProjectDB, $project);
-                $data = $this->getData($project, $dbForConsole, $dbForProject);
-                $csv->insertOne($data);
-            } catch (\Throwable $th) {
-                Console::error("Unexpected error occured with Project ID {$projectId}");
-                Console::error('[Error] Type: ' . get_class($th));
-                Console::error('[Error] Message: ' . $th->getMessage());
-                Console::error('[Error] File: ' . $th->getFile());
-                Console::error('[Error] Line: ' . $th->getLine());
-            }
-        });
-
-        $this->sendMail($register);
-    }
-
-    private function foreachDocument(Database $database, string $collection, array $queries = [], callable $callback = null): void
-    {
-        $limit = 1000;
-        $results = [];
-        $sum = $limit;
-        $latestDocument = null;
-
-        while ($sum === $limit) {
-            $newQueries = $queries;
-
-            if ($latestDocument != null) {
-                array_unshift($newQueries, Query::cursorAfter($latestDocument));
-            }
-            $newQueries[] = Query::limit($limit);
-            $results = $database->find('projects', $newQueries);
-
-            if (empty($results)) {
-                return;
-            }
-
-            $sum = count($results);
-
-            foreach ($results as $document) {
-                if (is_callable($callback)) {
-                    $callback($document);
-                }
-            }
-            $latestDocument = $results[array_key_last($results)];
-        }
-    }
-
-    private function sendMail(Registry $register): void
-    {
-        /** @var PHPMailer $mail */
-        $mail = $register->get('smtp');
-        $mail->clearAddresses();
-        $mail->clearAllRecipients();
-        $mail->clearReplyTos();
-        $mail->clearAttachments();
-        $mail->clearBCCs();
-        $mail->clearCCs();
-
-        try {
-            /** Addresses */
-            $mail->setFrom(App::getEnv('_APP_SYSTEM_EMAIL_ADDRESS', APP_EMAIL_TEAM), 'Appwrite Cloud Hamster');
-            $recipients = explode(',', App::getEnv('_APP_USERS_STATS_RECIPIENTS', ''));
-            foreach ($recipients as $recipient) {
-                $mail->addAddress($recipient);
-            }
-
-            /** Attachments */
-            $mail->addAttachment($this->path);
-
-            /** Content */
-            $mail->Subject = "Cloud Report for {$this->date}";
-            $mail->Body = "Please find the daily cloud report atttached";
-            $mail->send();
-            Console::success('Email has been sent!');
-        } catch (Exception $e) {
-            Console::error("Message could not be sent. Mailer Error: {$mail->ErrorInfo}");
-        }
-    }
-
-
-    private function getData(Document $project, Database $dbForConsole, Database $dbForProject): array
-    {
-        $stats['Project ID'] = $project->getId();
-        $stats['Organization ID']   = $project->getAttribute('teamId', null);
-
-        $teamInternalId = $project->getAttribute('teamInternalId', null);
-
-        if ($teamInternalId) {
-            $membership = $dbForConsole->findOne('memberships', [
-                Query::equal('teamInternalId', [$teamInternalId]),
-            ]);
-
-            if (!$membership || $membership->isEmpty()) {
-                Console::error('Membership not found. Skipping project : ' . $project->getId());
-            }
-
-            $userId = $membership->getAttribute('userId', null);
-            if ($userId) {
-                $user = $dbForConsole->getDocument('users', $userId);
-                $stats['Organization Email'] = $user->getAttribute('email', null);
-            }
-        } else {
-            Console::error("Email was not found for this Organization ID :{$teamInternalId}");
-        }
-
-        /** Get Total Members */
-        if ($teamInternalId) {
-            $stats['Organization Members'] = $dbForConsole->count('memberships', [
-                Query::equal('teamInternalId', [$teamInternalId])
-            ]);
-        } else {
-            $stats['Organization Members'] = 0;
-        }
-
-        /** Get Total internal Teams */
-        try {
-            $stats['Teams'] = $dbForProject->count('teams', []);
-        } catch (\Throwable) {
-            $stats['Teams'] = 0;
-        }
-
-        /** Get Total users */
-        try {
-            $stats['Users'] = $dbForProject->count('users', []);
-        } catch (\Throwable) {
-            $stats['Users'] = 0;
-        }
-
-        /** Get Usage stats */
-        $range = '30d';
-        $periods = [
-            '30d' => [
-                'period' => '1d',
-                'limit' => 30,
-            ]
-        ];
-
-        $tmp = [];
-        $metrics = $this->usageStats;
-        Authorization::skip(function () use ($dbForProject, $periods, $range, $metrics, &$tmp) {
-            foreach ($metrics as $metric => $name) {
-                $limit = $periods[$range]['limit'];
-                $period = $periods[$range]['period'];
-
-                $requestDocs = $dbForProject->find('stats_v2', [
-                    Query::equal('metric', [$metric]),
-                    Query::equal('period', [$period]),
-                    Query::limit($limit),
-                    Query::orderDesc('time'),
-                ]);
-
-                $tmp[$metric] = [];
-                foreach ($requestDocs as $requestDoc) {
-                    if (empty($requestDoc)) {
-                        continue;
-                    }
-
-                    $tmp[$metric][] = [
-                        'value' => $requestDoc->getAttribute('value'),
-                        'date' => $requestDoc->getAttribute('time'),
-                    ];
-                }
-
-                $tmp[$metric] = array_reverse($tmp[$metric]);
-                $tmp[$metric] = array_sum(array_column($tmp[$metric], 'value'));
-            }
-        });
-
-        foreach ($tmp as $key => $value) {
-            $stats[$metrics[$key]]  = $value;
-        }
-
-        /**
-         * Workaround to combine network.inbound+network.outbound as network.
-         */
-        $stats['Bandwidth'] = ($stats['Inbound'] ?? 0) + ($stats['Outbound'] ?? 0);
-        unset($stats['Inbound']);
-        unset($stats['Outbound']);
-
-        try {
-            /** Get Domains */
-            $stats['Domains'] = $dbForConsole->count('rules', [
-                Query::equal('projectInternalId', [$project->getInternalId()]),
-            ]);
-        } catch (\Throwable) {
-            $stats['Domains'] = 0;
-        }
-
-        try {
-            /** Get Api keys */
-            $stats['Api keys'] = $dbForConsole->count('keys', [
-                Query::equal('projectInternalId', [$project->getInternalId()]),
-            ]);
-        } catch (\Throwable) {
-            $stats['Api keys'] = 0;
-        }
-
-        try {
-            /** Get Webhooks */
-            $stats['Webhooks'] = $dbForConsole->count('webhooks', [
-                Query::equal('projectInternalId', [$project->getInternalId()]),
-            ]);
-        } catch (\Throwable) {
-            $stats['Webhooks'] = 0;
-        }
-
-        try {
-            /** Get Platforms */
-            $stats['Platforms'] = $dbForConsole->count('platforms', [
-                Query::equal('projectInternalId', [$project->getInternalId()]),
-            ]);
-        } catch (\Throwable) {
-            $stats['Platforms'] = 0;
-        }
-
-        /** Get Files & Buckets */
-        $filesCount = 0;
-        $filesSum = 0;
-        $maxFileSize = 0;
-        $counter = 0;
-        try {
-            $buckets = $dbForProject->find('buckets', []);
-            foreach ($buckets as $bucket) {
-                $file = $dbForProject->findOne('bucket_' . $bucket->getInternalId(), [Query::orderDesc('sizeOriginal'),]);
-                if (empty($file)) {
-                    continue;
-                }
-                $filesSum   += $dbForProject->sum('bucket_' . $bucket->getInternalId(), 'sizeOriginal', []);
-                $filesCount += $dbForProject->count('bucket_' . $bucket->getInternalId(), []);
-                if ($file->getAttribute('sizeOriginal') > $maxFileSize) {
-                    $maxFileSize = $file->getAttribute('sizeOriginal');
-                }
-                $counter++;
-            }
-        } catch (\Throwable $t) {
-            Console::error("Error while counting buckets: {$project->getId()}");
-        }
-        $stats['Buckets'] = $counter;
-        $stats['Files'] = $filesCount;
-        $stats['Storage (bytes)'] = $filesSum;
-        $stats['Max File Size (bytes)'] = $maxFileSize;
-
-
-        try {
-            /** Get Total Functions */
-            $stats['Databases'] = $dbForProject->count('databases', []);
-        } catch (\Throwable) {
-            $stats['Databases'] = 0;
-        }
-
-        /** Get Total Functions */
-        try {
-            $stats['Functions'] = $dbForProject->count('functions', []);
-        } catch (\Throwable) {
-            $stats['Functions'] = 0;
-        }
-
-        /** Get Total Deployments */
-        try {
-            $stats['Deployments'] = $dbForProject->count('deployments', []);
-        } catch (\Throwable) {
-            $stats['Deployments'] = 0;
-        }
-
-        /** Get Total Executions */
-        try {
-            $stats['Executions'] = $dbForProject->count('executions', []);
-        } catch (\Throwable) {
-            $stats['Executions'] = 0;
-        }
-
-        /** Get Total Migrations */
-        try {
-            $stats['Migrations'] = $dbForProject->count('migrations', []);
-        } catch (\Throwable) {
-            $stats['Migrations'] = 0;
-        }
-
-        return array_values($stats);
-    }
-}
diff --git a/src/Appwrite/Platform/Tasks/CreateInfMetric.php b/src/Appwrite/Platform/Tasks/CreateInfMetric.php
deleted file mode 100644
index 49b852ff6f..0000000000
--- a/src/Appwrite/Platform/Tasks/CreateInfMetric.php
+++ /dev/null
@@ -1,413 +0,0 @@
-<?php
-
-namespace Appwrite\Platform\Tasks;
-
-use Utopia\App;
-use Utopia\Database\Document;
-use Utopia\Database\Exception;
-use Utopia\Database\Exception\Duplicate;
-use Utopia\Database\Query;
-use Utopia\Platform\Action;
-use Utopia\Cache\Cache;
-use Utopia\CLI\Console;
-use Utopia\Database\Database;
-use Utopia\Pools\Group;
-use Utopia\Registry\Registry;
-use Utopia\Validator\Text;
-
-class CreateInfMetric extends Action
-{
-    public static function getName(): string
-    {
-        return 'create-inf-metric';
-    }
-
-    public function __construct()
-    {
-
-        $this
-            ->desc('Create infinity stats metric')
-            ->param('after', '', new Text(36), 'After cursor', true)
-            ->param('projectId', '', new Text(36), 'Select project to validate', true)
-            ->inject('getProjectDB')
-            ->inject('dbForConsole')
-            ->callback(function (string $after, string $projectId, callable $getProjectDB, Database $dbForConsole) {
-                $this->action($after, $projectId, $getProjectDB, $dbForConsole);
-            });
-    }
-
-
-    /**
-     * @throws Exception
-     * @throws Exception\Timeout
-     * @throws Exception\Query
-     */
-    public function action(string $after, string $projectId, callable $getProjectDB, Database $dbForConsole): void
-    {
-
-        Console::title('Create infinity metric V1');
-        Console::success(APP_NAME . ' Create infinity metric started');
-
-        if (!empty($projectId)) {
-            try {
-                $project = $dbForConsole->getDocument('projects', $projectId);
-                $dbForProject = call_user_func($getProjectDB, $project);
-                $this->getUsageData($dbForProject, $project);
-            } catch (\Throwable $th) {
-                Console::error("Unexpected error occured with Project ID {$projectId}");
-                Console::error('[Error] Type: ' . get_class($th));
-                Console::error('[Error] Message: ' . $th->getMessage());
-                Console::error('[Error] File: ' . $th->getFile());
-                Console::error('[Error] Line: ' . $th->getLine());
-            }
-        } else {
-            $queries = [];
-            if (!empty($after)) {
-                Console::info("Iterating remaining projects after project with ID {$after}");
-                $project = $dbForConsole->getDocument('projects', $after);
-                $queries = [Query::cursorAfter($project)];
-            } else {
-                Console::info("Iterating all projects");
-            }
-            $this->foreachDocument($dbForConsole, 'projects', $queries, function (Document $project) use ($getProjectDB) {
-                $projectId = $project->getId();
-
-                try {
-                    $dbForProject = call_user_func($getProjectDB, $project);
-                    $this->getUsageData($dbForProject, $project);
-                } catch (\Throwable $th) {
-                    Console::error("Unexpected error occured with Project ID {$projectId}");
-                    Console::error('[Error] Type: ' . get_class($th));
-                    Console::error('[Error] Message: ' . $th->getMessage());
-                    Console::error('[Error] File: ' . $th->getFile());
-                    Console::error('[Error] Line: ' . $th->getLine());
-                }
-            });
-        }
-    }
-
-    /**
-     * @param Database $database
-     * @param string $collection
-     * @param array $queries
-     * @param callable|null $callback
-     * @return void
-     * @throws Exception
-     * @throws Exception\Query
-     * @throws Exception\Timeout
-     */
-    private function foreachDocument(Database $database, string $collection, array $queries = [], callable $callback = null): void
-    {
-        $limit = 1000;
-        $results = [];
-        $sum = $limit;
-        $latestDocument = null;
-
-        while ($sum === $limit) {
-            $newQueries = $queries;
-
-            if ($latestDocument != null) {
-                array_unshift($newQueries, Query::cursorAfter($latestDocument));
-            }
-            $newQueries[] = Query::limit($limit);
-            $results = $database->find($collection, $newQueries);
-
-            if (empty($results)) {
-                return;
-            }
-
-            $sum = count($results);
-
-            foreach ($results as $document) {
-                if (is_callable($callback)) {
-                    $callback($document);
-                }
-            }
-            $latestDocument = $results[array_key_last($results)];
-        }
-    }
-
-
-    /**
-     * @param Database $dbForProject
-     * @param Document $project
-     * @return void
-     */
-    private function getUsageData(Database $dbForProject, Document $project): void
-    {
-        try {
-            $this->network($dbForProject);
-            $this->sessions($dbForProject);
-            $this->users($dbForProject);
-            $this->teams($dbForProject);
-            $this->databases($dbForProject);
-            $this->functions($dbForProject);
-            $this->storage($dbForProject);
-        } catch (\Throwable $th) {
-            var_dump($th->getMessage());
-        }
-
-        Console::log('Finished project ' . $project->getId() . ' ' . $project->getInternalId());
-    }
-
-
-    /**
-     * @param Database $dbForProject
-     * @param string $metric
-     * @param int|float $value
-     * @return void
-     * @throws Exception
-     * @throws Exception\Authorization
-     * @throws Exception\Conflict
-     * @throws Exception\Restricted
-     * @throws Exception\Structure
-     */
-    private function createInfMetric(database $dbForProject, string $metric, int|float $value): void
-    {
-
-        try {
-            $id = \md5("_inf_{$metric}");
-            $dbForProject->deleteDocument('stats_v2', $id);
-            $dbForProject->createDocument('stats_v2', new Document([
-                '$id' => $id,
-                'metric' => $metric,
-                'period' => 'inf',
-                'value'  => (int)$value,
-                'time'   => null,
-                'region' => 'default',
-            ]));
-        } catch (Duplicate $th) {
-            console::log("Error while creating inf metric: duplicate id {$metric}  {$id}");
-        }
-    }
-
-    /**
-     * @param Database $dbForProject
-     * @param string $metric
-     * @return int|float
-     * @throws Exception
-     */
-    protected function getFromMetric(database $dbForProject, string $metric): int|float
-    {
-
-        return  $dbForProject->sum('stats_v2', 'value', [
-            Query::equal('metric', [
-                $metric,
-            ]),
-            Query::equal('period', ['1d']),
-        ]);
-    }
-
-    /**
-     * @param Database $dbForProject
-     * @throws Exception
-     * @throws Exception\Authorization
-     * @throws Exception\Conflict
-     * @throws Exception\Restricted
-     * @throws Exception\Structure
-     */
-    private function network(database $dbForProject)
-    {
-        $this->createInfMetric($dbForProject, 'network.inbound', $this->getFromMetric($dbForProject, 'network.inbound'));
-        $this->createInfMetric($dbForProject, 'network.outbound', $this->getFromMetric($dbForProject, 'network.outbound'));
-        $this->createInfMetric($dbForProject, 'network.requests', $this->getFromMetric($dbForProject, 'network.requests'));
-    }
-
-
-    /**
-     * @throws Exception\Authorization
-     * @throws Exception\Restricted
-     * @throws Exception\Conflict
-     * @throws Exception\Timeout
-     * @throws Exception\Structure
-     * @throws Exception
-     * @throws Exception\Query
-     */
-    private function storage(database $dbForProject)
-    {
-        $bucketsCount = 0;
-        $filesCount = 0;
-        $filesStorageSum = 0;
-
-        $buckets = $dbForProject->find('buckets');
-        foreach ($buckets as $bucket) {
-            $files = $dbForProject->count('bucket_' . $bucket->getInternalId());
-            $this->createInfMetric($dbForProject, $bucket->getInternalId() . '.files', $files);
-
-            $filesStorage = $dbForProject->sum('bucket_' . $bucket->getInternalId(), 'sizeOriginal');
-            $this->createInfMetric($dbForProject, $bucket->getInternalId() . '.files.storage', $filesStorage);
-
-            $bucketsCount++;
-            $filesCount += $files;
-            $filesStorageSum += $filesStorage;
-        }
-
-        $this->createInfMetric($dbForProject, 'buckets', $bucketsCount);
-        $this->createInfMetric($dbForProject, 'files', $filesCount);
-        $this->createInfMetric($dbForProject, 'files.storage', $filesStorageSum);
-    }
-
-
-    /**
-     * @throws Exception\Authorization
-     * @throws Exception\Timeout
-     * @throws Exception\Restricted
-     * @throws Exception\Structure
-     * @throws Exception\Conflict
-     * @throws Exception
-     * @throws Exception\Query
-     */
-    private function functions(Database $dbForProject)
-    {
-        $functionsCount = 0;
-        $deploymentsCount = 0;
-        $buildsCount = 0;
-        $buildsStorageSum = 0;
-        $buildsComputeSum = 0;
-        $executionsCount = 0;
-        $executionsComputeSum = 0;
-        $deploymentsStorageSum = 0;
-
-        //functions
-        $functions = $dbForProject->find('functions');
-        foreach ($functions as $function) {
-            //deployments
-            $deployments = $dbForProject->find('deployments', [
-                Query::equal('resourceType', ['functions']),
-                Query::equal('resourceInternalId', [$function->getInternalId()]),
-            ]);
-
-            $deploymentCount = 0;
-            $deploymentStorageSum = 0;
-            foreach ($deployments as $deployment) {
-                //builds
-                $builds = $dbForProject->count('builds', [
-                    Query::equal('deploymentInternalId', [$deployment->getInternalId()]),
-                ]);
-
-                $buildsCompute = $dbForProject->sum('builds', 'duration', [
-                    Query::equal('deploymentInternalId', [$deployment->getInternalId()]),
-                ]);
-
-                $buildsStorage = $dbForProject->sum('builds', 'size', [
-                    Query::equal('deploymentInternalId', [$deployment->getInternalId()]),
-                ]);
-
-                $this->createInfMetric($dbForProject, $function->getInternalId() . '.builds', $builds);
-                $this->createInfMetric($dbForProject, $function->getInternalId() . '.builds.storage', $buildsCompute * 1000);
-                $this->createInfMetric($dbForProject, $function->getInternalId() . '.builds.compute', $buildsStorage);
-
-                $buildsCount += $builds;
-                $buildsComputeSum += $buildsCompute;
-                $buildsStorageSum += $buildsStorage;
-
-
-                $deploymentCount++;
-                $deploymentsCount++;
-                $deploymentsStorageSum += $deployment['size'];
-                $deploymentStorageSum += $deployment['size'];
-            }
-            $this->createInfMetric($dbForProject, 'functions.' . $function->getInternalId() . '.deployments', $deploymentCount);
-            $this->createInfMetric($dbForProject, 'functions.' . $function->getInternalId() . '.deployments.storage', $deploymentStorageSum);
-
-            //executions
-            $executions = $dbForProject->count('executions', [
-                Query::equal('functionInternalId', [$function->getInternalId()]),
-            ]);
-
-            $executionsCompute = $dbForProject->sum('executions', 'duration', [
-                Query::equal('functionInternalId', [$function->getInternalId()]),
-            ]);
-
-            $this->createInfMetric($dbForProject, $function->getInternalId() . '.executions', $executions);
-            $this->createInfMetric($dbForProject, $function->getInternalId() . '.executions.compute', $executionsCompute * 1000);
-            $executionsCount += $executions;
-            $executionsComputeSum += $executionsCompute;
-
-            $functionsCount++;
-        }
-
-        $this->createInfMetric($dbForProject, 'functions', $functionsCount);
-        $this->createInfMetric($dbForProject, 'deployments', $deploymentsCount);
-        $this->createInfMetric($dbForProject, 'deployments.storage', $deploymentsStorageSum);
-        $this->createInfMetric($dbForProject, 'builds', $buildsCount);
-        $this->createInfMetric($dbForProject, 'builds.compute', $buildsComputeSum * 1000);
-        $this->createInfMetric($dbForProject, 'builds.storage', $buildsStorageSum);
-        $this->createInfMetric($dbForProject, 'executions', $executionsCount);
-        $this->createInfMetric($dbForProject, 'executions.compute', $executionsComputeSum * 1000);
-    }
-
-    /**
-     * @throws Exception\Authorization
-     * @throws Exception\Timeout
-     * @throws Exception\Structure
-     * @throws Exception\Restricted
-     * @throws Exception\Conflict
-     * @throws Exception
-     * @throws Exception\Query
-     */
-    private function databases(Database $dbForProject)
-    {
-        $databasesCount = 0;
-        $collectionsCount = 0;
-        $documentsCount = 0;
-        $databases = $dbForProject->find('databases');
-        foreach ($databases as $database) {
-            $collectionCount = 0;
-            $collections = $dbForProject->find('database_' . $database->getInternalId());
-            foreach ($collections as $collection) {
-                $documents = $dbForProject->count('database_' . $database->getInternalId() . '_collection_' . $collection->getInternalId());
-                $this->createInfMetric($dbForProject, $database->getInternalId() . '.' . $collection->getInternalId() . '.documents', $documents);
-                $documentsCount += $documents;
-                $collectionCount++;
-                $collectionsCount++;
-            }
-            $this->createInfMetric($dbForProject, $database->getInternalId() . '.collections', $collectionCount);
-            $this->createInfMetric($dbForProject, $database->getInternalId() . '.documents', $documentsCount);
-            $databasesCount++;
-        }
-        $this->createInfMetric($dbForProject, 'collections', $collectionsCount);
-        $this->createInfMetric($dbForProject, 'databases', $databasesCount);
-        $this->createInfMetric($dbForProject, 'documents', $documentsCount);
-    }
-
-
-    /**
-     * @throws Exception\Authorization
-     * @throws Exception\Structure
-     * @throws Exception\Restricted
-     * @throws Exception\Conflict
-     * @throws Exception
-     */
-    private function users(Database $dbForProject)
-    {
-        $users = $dbForProject->count('users');
-        $this->createInfMetric($dbForProject, 'users', $users);
-    }
-
-    /**
-     * @throws Exception\Authorization
-     * @throws Exception\Structure
-     * @throws Exception\Restricted
-     * @throws Exception\Conflict
-     * @throws Exception
-     */
-    private function sessions(Database $dbForProject)
-    {
-        $users = $dbForProject->count('sessions');
-        $this->createInfMetric($dbForProject, 'sessions', $users);
-    }
-
-    /**
-     * @throws Exception\Authorization
-     * @throws Exception\Structure
-     * @throws Exception\Restricted
-     * @throws Exception\Conflict
-     * @throws Exception
-     */
-    private function teams(Database $dbForProject)
-    {
-        $teams = $dbForProject->count('teams');
-        $this->createInfMetric($dbForProject, 'teams', $teams);
-    }
-}
diff --git a/src/Appwrite/Platform/Tasks/DeleteOrphanedProjects.php b/src/Appwrite/Platform/Tasks/DeleteOrphanedProjects.php
deleted file mode 100644
index 757b29c1b6..0000000000
--- a/src/Appwrite/Platform/Tasks/DeleteOrphanedProjects.php
+++ /dev/null
@@ -1,161 +0,0 @@
-<?php
-
-namespace Appwrite\Platform\Tasks;
-
-use Utopia\App;
-use Utopia\Config\Config;
-use Utopia\Database\Helpers\ID;
-use Utopia\Database\Query;
-use Utopia\Platform\Action;
-use Utopia\Cache\Cache;
-use Utopia\CLI\Console;
-use Utopia\Database\Database;
-use Utopia\Pools\Group;
-use Utopia\Registry\Registry;
-use Utopia\Validator\Boolean;
-
-class DeleteOrphanedProjects extends Action
-{
-    public static function getName(): string
-    {
-        return 'delete-orphaned-projects';
-    }
-
-    public function __construct()
-    {
-
-        $this
-            ->desc('Delete orphaned projects')
-            ->param('commit', false, new Boolean(true), 'Commit  project deletion', true)
-            ->inject('pools')
-            ->inject('cache')
-            ->inject('dbForConsole')
-            ->inject('register')
-            ->callback(function (bool $commit, Group $pools, Cache $cache, Database $dbForConsole, Registry $register) {
-                $this->action($commit, $pools, $cache, $dbForConsole, $register);
-            });
-    }
-
-
-    public function action(bool $commit, Group $pools, Cache $cache, Database $dbForConsole, Registry $register): void
-    {
-
-        Console::title('Delete orphaned projects V1');
-        Console::success(APP_NAME . ' Delete orphaned projects started');
-
-        /** @var array $collections */
-        $collectionsConfig = Config::getParam('collections', [])['projects'] ?? [];
-
-        $collectionsConfig = array_merge([
-            'audit' => [
-                '$id' => ID::custom('audit'),
-                '$collection' => Database::METADATA
-            ],
-            'abuse' => [
-                '$id' => ID::custom('abuse'),
-                '$collection' => Database::METADATA
-            ]
-        ], $collectionsConfig);
-
-        /* Initialise new Utopia app */
-        $app = new App('UTC');
-        $console = $app->getResource('console');
-        $projects = [$console];
-
-        /** Database connections */
-        $totalProjects = $dbForConsole->count('projects');
-        Console::success("Found a total of: {$totalProjects} projects");
-
-        $orphans = 1;
-        $cnt = 0;
-        $count = 0;
-        $limit = 30;
-        $sum = 30;
-        $offset = 0;
-        while (!empty($projects)) {
-            foreach ($projects as $project) {
-
-                /**
-                 * Skip user projects with id 'console'
-                 */
-                if ($project->getId() === 'console') {
-                    continue;
-                }
-
-                try {
-                    $db = $project->getAttribute('database');
-                    $adapter = $pools
-                        ->get($db)
-                        ->pop()
-                        ->getResource();
-
-                    $dbForProject = new Database($adapter, $cache);
-                    $dbForProject->setDefaultDatabase('appwrite');
-                    $dbForProject->setNamespace('_' . $project->getInternalId());
-
-                    $collectionsCreated = 0;
-                    $cnt++;
-                    if ($dbForProject->exists($dbForProject->getDefaultDatabase(), Database::METADATA)) {
-                        $collectionsCreated = $dbForProject->count(Database::METADATA);
-                    }
-
-                    $msg = '(' . $cnt . ') found (' . $collectionsCreated . ') collections on project  (' . $project->getInternalId() . ') , database (' . $project['database'] . ')';
-
-                    if ($collectionsCreated >= count($collectionsConfig)) {
-                        Console::log($msg . ' ignoring....');
-                        continue;
-                    }
-
-                    Console::log($msg);
-
-                    if ($collectionsCreated > 0) {
-                        $collections = $dbForProject->find(Database::METADATA, []);
-                        foreach ($collections as $collection) {
-                            if ($commit) {
-                                $dbForProject->deleteCollection($collection->getId());
-                                $dbForConsole->deleteCachedCollection($collection->getId());
-                            }
-                            Console::info('--Deleting collection  (' . $collection->getId() . ') project no (' . $project->getInternalId() . ')');
-                        }
-                    }
-
-                    if ($commit) {
-                        $dbForConsole->deleteDocument('projects', $project->getId());
-                        $dbForConsole->deleteCachedDocument('projects', $project->getId());
-
-                        if ($dbForProject->exists($dbForProject->getDefaultDatabase(), Database::METADATA)) {
-                            try {
-                                $dbForProject->deleteCollection(Database::METADATA);
-                                $dbForProject->deleteCachedCollection(Database::METADATA);
-                            } catch (\Throwable $th) {
-                                Console::warning('Metadata collection does not exist');
-                            }
-                        }
-                    }
-
-                    Console::info('--Deleting project no (' . $project->getInternalId() . ')');
-
-                    $orphans++;
-                } catch (\Throwable $th) {
-                    Console::error('Error: ' . $th->getMessage() . ' ' . $th->getTraceAsString());
-                } finally {
-                    $pools
-                        ->get($db)
-                        ->reclaim();
-                }
-            }
-
-            $sum = \count($projects);
-
-            $projects = $dbForConsole->find('projects', [
-                Query::limit($limit),
-                Query::offset($offset),
-            ]);
-
-            $offset = $offset + $limit;
-            $count = $count + $sum;
-        }
-
-        Console::log('Iterated through ' . $count - 1 . '/' . $totalProjects . ' projects found ' . $orphans - 1 . ' orphans');
-    }
-}
diff --git a/src/Appwrite/Platform/Tasks/GetMigrationStats.php b/src/Appwrite/Platform/Tasks/GetMigrationStats.php
deleted file mode 100644
index b76e0428d7..0000000000
--- a/src/Appwrite/Platform/Tasks/GetMigrationStats.php
+++ /dev/null
@@ -1,187 +0,0 @@
-<?php
-
-namespace Appwrite\Platform\Tasks;
-
-use Exception;
-use League\Csv\CannotInsertRecord;
-use Utopia\App;
-use Utopia\Platform\Action;
-use Utopia\Cache\Cache;
-use Utopia\CLI\Console;
-use Utopia\Database\Database;
-use Utopia\Database\Query;
-use League\Csv\Writer;
-use PHPMailer\PHPMailer\PHPMailer;
-use Utopia\Pools\Group;
-use Utopia\Registry\Registry;
-
-class GetMigrationStats extends Action
-{
-    /*
-     * Csv cols headers
-     */
-    private array $columns = [
-        'Project ID',
-        '$id',
-        '$createdAt',
-        'status',
-        'stage',
-        'source'
-    ];
-
-    protected string $directory = '/usr/local';
-    protected string $path;
-    protected string $date;
-
-    public static function getName(): string
-    {
-        return 'get-migration-stats';
-    }
-
-    public function __construct()
-    {
-
-        $this
-            ->desc('Get stats for projects')
-            ->inject('pools')
-            ->inject('cache')
-            ->inject('dbForConsole')
-            ->inject('register')
-            ->callback(function (Group $pools, Cache $cache, Database $dbForConsole, Registry $register) {
-                $this->action($pools, $cache, $dbForConsole, $register);
-            });
-    }
-
-    /**
-     * @throws \Utopia\Exception
-     * @throws CannotInsertRecord
-     */
-    public function action(Group $pools, Cache $cache, Database $dbForConsole, Registry $register): void
-    {
-        //docker compose exec -t appwrite get-migration-stats
-
-        Console::title('Migration stats calculation V1');
-        Console::success(APP_NAME . ' Migration stats calculation has started');
-
-        /* Initialise new Utopia app */
-        $app = new App('UTC');
-        $console = $app->getResource('console');
-
-        /** CSV stuff */
-        $this->date = date('Y-m-d');
-        $this->path = "{$this->directory}/migration_stats_{$this->date}.csv";
-        $csv = Writer::createFromPath($this->path, 'w');
-        $csv->insertOne($this->columns);
-
-        /** Database connections */
-        $totalProjects = $dbForConsole->count('projects');
-        Console::success("Found a total of: {$totalProjects} projects");
-
-        $projects = [$console];
-        $count = 0;
-        $limit = 100;
-        $sum = 100;
-        $offset = 0;
-        while (!empty($projects)) {
-            foreach ($projects as $project) {
-
-                /**
-                 * Skip user projects with id 'console'
-                 */
-                if ($project->getId() === 'console') {
-                    continue;
-                }
-
-                Console::info("Getting stats for {$project->getId()}");
-
-                try {
-                    $db = $project->getAttribute('database');
-                    $adapter = $pools
-                        ->get($db)
-                        ->pop()
-                        ->getResource();
-
-                    $dbForProject = new Database($adapter, $cache);
-                    $dbForProject->setDefaultDatabase('appwrite');
-                    $dbForProject->setNamespace('_' . $project->getInternalId());
-
-                    /** Get Project ID */
-                    $stats['Project ID'] = $project->getId();
-
-                    /** Get Migration details */
-                    $migrations = $dbForProject->find('migrations', [
-                        Query::limit(500)
-                    ]);
-
-                    $migrations = array_map(function ($migration) use ($project) {
-                        return [
-                            $project->getId(),
-                            $migration->getAttribute('$id'),
-                            $migration->getAttribute('$createdAt'),
-                            $migration->getAttribute('status'),
-                            $migration->getAttribute('stage'),
-                            $migration->getAttribute('source'),
-                        ];
-                    }, $migrations);
-
-                    if (!empty($migrations)) {
-                        $csv->insertAll($migrations);
-                    }
-                } catch (\Throwable $th) {
-                    Console::error('Failed on project ("' . $project->getId() . '") with error on File: ' . $th->getFile() . '  line no: ' . $th->getline() . ' with message: ' . $th->getMessage());
-                } finally {
-                    $pools
-                        ->get($db)
-                        ->reclaim();
-                }
-            }
-
-            $sum = \count($projects);
-
-            $projects = $dbForConsole->find('projects', [
-                Query::limit($limit),
-                Query::offset($offset),
-            ]);
-
-            $offset = $offset + $limit;
-            $count = $count + $sum;
-        }
-
-        Console::log('Iterated through ' . $count - 1 . '/' . $totalProjects . ' projects...');
-
-        $pools
-            ->get('console')
-            ->reclaim();
-
-        /** @var PHPMailer $mail */
-        $mail = $register->get('smtp');
-
-        $mail->clearAddresses();
-        $mail->clearAllRecipients();
-        $mail->clearReplyTos();
-        $mail->clearAttachments();
-        $mail->clearBCCs();
-        $mail->clearCCs();
-
-        try {
-            /** Addresses */
-            $mail->setFrom(App::getEnv('_APP_SYSTEM_EMAIL_ADDRESS', APP_EMAIL_TEAM), 'Appwrite Cloud Hamster');
-            $recipients = explode(',', App::getEnv('_APP_USERS_STATS_RECIPIENTS', ''));
-
-            foreach ($recipients as $recipient) {
-                $mail->addAddress($recipient);
-            }
-
-            /** Attachments */
-            $mail->addAttachment($this->path);
-
-            /** Content */
-            $mail->Subject = "Migration Report for {$this->date}";
-            $mail->Body = "Please find the migration report atttached";
-            $mail->send();
-            Console::success('Email has been sent!');
-        } catch (Exception $e) {
-            Console::error("Message could not be sent. Mailer Error: {$mail->ErrorInfo}");
-        }
-    }
-}
diff --git a/src/Appwrite/Platform/Tasks/Hamster.php b/src/Appwrite/Platform/Tasks/Hamster.php
deleted file mode 100644
index 1dca095e93..0000000000
--- a/src/Appwrite/Platform/Tasks/Hamster.php
+++ /dev/null
@@ -1,158 +0,0 @@
-<?php
-
-namespace Appwrite\Platform\Tasks;
-
-use Appwrite\Event\Hamster as EventHamster;
-use Exception;
-use Utopia\App;
-use Utopia\Platform\Action;
-use Utopia\CLI\Console;
-use Utopia\Database\Database;
-use Utopia\Database\Query;
-use Utopia\Database\Document;
-
-class Hamster extends Action
-{
-    public static function getName(): string
-    {
-        return 'hamster';
-    }
-
-    public function __construct()
-    {
-        $this
-            ->desc('Get stats for projects')
-            ->inject('queueForHamster')
-            ->inject('dbForConsole')
-            ->callback(function (EventHamster $queueForHamster, Database $dbForConsole) {
-                $this->action($queueForHamster, $dbForConsole);
-            });
-    }
-
-    public function action(EventHamster $queueForHamster, Database $dbForConsole): void
-    {
-        Console::title('Cloud Hamster V1');
-        Console::success(APP_NAME . ' cloud hamster process has started');
-
-        $sleep = (int) App::getEnv('_APP_HAMSTER_INTERVAL', '30'); // 30 seconds (by default)
-
-        $jobInitTime = App::getEnv('_APP_HAMSTER_TIME', '22:00'); // (hour:minutes)
-
-        $now = new \DateTime();
-        $now->setTimezone(new \DateTimeZone(date_default_timezone_get()));
-
-        $next = new \DateTime($now->format("Y-m-d $jobInitTime"));
-        $next->setTimezone(new \DateTimeZone(date_default_timezone_get()));
-
-        $delay = $next->getTimestamp() - $now->getTimestamp();
-        /**
-         * If time passed for the target day.
-         */
-        if ($delay <= 0) {
-            $next->add(\DateInterval::createFromDateString('1 days'));
-            $delay = $next->getTimestamp() - $now->getTimestamp();
-        }
-
-        Console::log('[' . $now->format("Y-m-d H:i:s.v") . '] Delaying for ' . $delay . ' setting loop to [' . $next->format("Y-m-d H:i:s.v") . ']');
-
-        Console::loop(function () use ($queueForHamster, $dbForConsole, $sleep) {
-            $now = date('d-m-Y H:i:s', time());
-            Console::info("[{$now}] Queuing Cloud Usage Stats every {$sleep} seconds");
-            $loopStart = microtime(true);
-
-            Console::info('Queuing stats for all projects');
-            $this->getStatsPerProject($queueForHamster, $dbForConsole, $loopStart);
-            Console::success('Completed queuing stats for all projects');
-
-            Console::info('Queuing stats for all organizations');
-            $this->getStatsPerOrganization($queueForHamster, $dbForConsole, $loopStart);
-            Console::success('Completed queuing stats for all organizations');
-
-            Console::info('Queuing stats for all users');
-            $this->getStatsPerUser($queueForHamster, $dbForConsole, $loopStart);
-            Console::success('Completed queuing stats for all users');
-
-            $loopTook = microtime(true) - $loopStart;
-            $now = date('d-m-Y H:i:s', time());
-            Console::info("[{$now}] Cloud Stats took {$loopTook} seconds");
-        }, $sleep, $delay);
-    }
-
-    protected function calculateByGroup(string $collection, Database $database, callable $callback)
-    {
-        $count = 0;
-        $chunk = 0;
-        $limit = 50;
-        $results = [];
-        $sum = $limit;
-
-        $executionStart = \microtime(true);
-
-        while ($sum === $limit) {
-            $chunk++;
-
-            $results = $database->find($collection, \array_merge([
-                Query::limit($limit),
-                Query::offset($count)
-            ]));
-
-            $sum = count($results);
-
-            Console::log('Processing chunk #' . $chunk . '. Found ' . $sum . ' documents');
-
-            foreach ($results as $document) {
-                call_user_func($callback, $database, $document);
-                $count++;
-            }
-        }
-
-        $executionEnd = \microtime(true);
-
-        Console::log("Processed {$count} document by group in " . ($executionEnd - $executionStart) . " seconds");
-    }
-
-    protected function getStatsPerOrganization(EventHamster $hamster, Database $dbForConsole, float $loopStart)
-    {
-        $this->calculateByGroup('teams', $dbForConsole, function (Database $dbForConsole, Document $organization) use ($hamster, $loopStart) {
-            try {
-                $organization->setAttribute('$time', $loopStart);
-                $hamster
-                    ->setType(EventHamster::TYPE_ORGANISATION)
-                    ->setOrganization($organization)
-                    ->trigger();
-            } catch (Exception $e) {
-                Console::error($e->getMessage());
-            }
-        });
-    }
-
-    private function getStatsPerProject(EventHamster $hamster, Database $dbForConsole, float $loopStart)
-    {
-        $this->calculateByGroup('projects', $dbForConsole, function (Database $dbForConsole, Document $project) use ($hamster, $loopStart) {
-            try {
-                $project->setAttribute('$time', $loopStart);
-                $hamster
-                    ->setType(EventHamster::TYPE_PROJECT)
-                    ->setProject($project)
-                    ->trigger();
-            } catch (Exception $e) {
-                Console::error($e->getMessage());
-            }
-        });
-    }
-
-    protected function getStatsPerUser(EventHamster $hamster, Database $dbForConsole, float $loopStart)
-    {
-        $this->calculateByGroup('users', $dbForConsole, function (Database $dbForConsole, Document $user) use ($hamster, $loopStart) {
-            try {
-                $user->setAttribute('$time', $loopStart);
-                $hamster
-                    ->setType(EventHamster::TYPE_USER)
-                    ->setUser($user)
-                    ->trigger();
-            } catch (Exception $e) {
-                Console::error($e->getMessage());
-            }
-        });
-    }
-}
diff --git a/src/Appwrite/Platform/Tasks/PatchRecreateRepositoriesDocuments.php b/src/Appwrite/Platform/Tasks/PatchRecreateRepositoriesDocuments.php
deleted file mode 100644
index 93e6c527bb..0000000000
--- a/src/Appwrite/Platform/Tasks/PatchRecreateRepositoriesDocuments.php
+++ /dev/null
@@ -1,169 +0,0 @@
-<?php
-
-namespace Appwrite\Platform\Tasks;
-
-use Utopia\Platform\Action;
-use Utopia\CLI\Console;
-use Utopia\Database\Database;
-use Utopia\Database\Document;
-use Utopia\Database\Helpers\ID;
-use Utopia\Database\Helpers\Permission;
-use Utopia\Database\Helpers\Role;
-use Utopia\Database\Query;
-use Utopia\Validator\Text;
-
-class PatchRecreateRepositoriesDocuments extends Action
-{
-    public static function getName(): string
-    {
-        return 'patch-recreate-repositories-documents';
-    }
-
-    public function __construct()
-    {
-        $this
-            ->desc('Recreate missing repositories in consoleDB from projectDBs. They can be missing if you used Appwrite 1.4.10 or 1.4.11, and deleted a function.')
-            ->param('after', '', new Text(36), 'After cursor', true)
-            ->param('projectId', '', new Text(36), 'Select project to validate', true)
-            ->inject('dbForConsole')
-            ->inject('getProjectDB')
-            ->callback(fn ($after, $projectId, $dbForConsole, $getProjectDB) => $this->action($after, $projectId, $dbForConsole, $getProjectDB));
-    }
-
-    public function action($after, $projectId, Database $dbForConsole, callable $getProjectDB): void
-    {
-        Console::info("Starting the patch");
-
-        $startTime = microtime(true);
-
-        if (!empty($projectId)) {
-            try {
-                $project = $dbForConsole->getDocument('projects', $projectId);
-                $dbForProject = call_user_func($getProjectDB, $project);
-                $this->recreateRepositories($dbForConsole, $dbForProject, $project);
-            } catch (\Throwable $th) {
-                Console::error("Unexpected error occured with Project ID {$projectId}");
-                Console::error('[Error] Type: ' . get_class($th));
-                Console::error('[Error] Message: ' . $th->getMessage());
-                Console::error('[Error] File: ' . $th->getFile());
-                Console::error('[Error] Line: ' . $th->getLine());
-            }
-        } else {
-            $queries = [];
-            if (!empty($after)) {
-                Console::info("Iterating remaining projects after project with ID {$after}");
-                $project = $dbForConsole->getDocument('projects', $after);
-                $queries = [Query::cursorAfter($project)];
-            } else {
-                Console::info("Iterating all projects");
-            }
-            $this->foreachDocument($dbForConsole, 'projects', $queries, function (Document $project) use ($getProjectDB, $dbForConsole) {
-                $projectId = $project->getId();
-
-                try {
-                    $dbForProject = call_user_func($getProjectDB, $project);
-                    $this->recreateRepositories($dbForConsole, $dbForProject, $project);
-                } catch (\Throwable $th) {
-                    Console::error("Unexpected error occured with Project ID {$projectId}");
-                    Console::error('[Error] Type: ' . get_class($th));
-                    Console::error('[Error] Message: ' . $th->getMessage());
-                    Console::error('[Error] File: ' . $th->getFile());
-                    Console::error('[Error] Line: ' . $th->getLine());
-                }
-            });
-        }
-
-        $endTime = microtime(true);
-        $timeTaken = $endTime - $startTime;
-
-        $hours = (int)($timeTaken / 3600);
-        $timeTaken -= $hours * 3600;
-        $minutes = (int)($timeTaken / 60);
-        $timeTaken -= $minutes * 60;
-        $seconds = (int)$timeTaken;
-        $milliseconds = ($timeTaken - $seconds) * 1000;
-        Console::info("Recreate patch completed in $hours h, $minutes m, $seconds s, $milliseconds mis ( total $timeTaken milliseconds)");
-    }
-
-    protected function foreachDocument(Database $database, string $collection, array $queries = [], callable $callback = null): void
-    {
-        $limit = 1000;
-        $results = [];
-        $sum = $limit;
-        $latestDocument = null;
-
-        while ($sum === $limit) {
-            $newQueries = $queries;
-
-            if ($latestDocument != null) {
-                array_unshift($newQueries, Query::cursorAfter($latestDocument));
-            }
-            $newQueries[] = Query::limit($limit);
-            $results = $database->find($collection, $newQueries);
-
-            if (empty($results)) {
-                return;
-            }
-
-            $sum = count($results);
-
-            foreach ($results as $document) {
-                if (is_callable($callback)) {
-                    $callback($document);
-                }
-            }
-            $latestDocument = $results[array_key_last($results)];
-        }
-    }
-
-    public function recreateRepositories(Database $dbForConsole, Database $dbForProject, Document $project): void
-    {
-        $projectId = $project->getId();
-        Console::log("Running patch for project {$projectId}");
-
-        $this->foreachDocument($dbForProject, 'functions', [], function (Document $function) use ($dbForProject, $dbForConsole, $project) {
-            $isConnected = !empty($function->getAttribute('providerRepositoryId', ''));
-
-            if ($isConnected) {
-                $repository = $dbForConsole->getDocument('repositories', $function->getAttribute('repositoryId', ''));
-
-                if ($repository->isEmpty()) {
-                    $projectId = $project->getId();
-                    $functionId = $function->getId();
-                    Console::success("Recreating repositories document for project ID {$projectId}, function ID {$functionId}");
-
-                    $repository = $dbForConsole->createDocument('repositories', new Document([
-                        '$id' => ID::unique(),
-                        '$permissions' => [
-                            Permission::read(Role::any()),
-                            Permission::update(Role::any()),
-                            Permission::delete(Role::any()),
-                        ],
-                        'installationId' => $function->getAttribute('installationId', ''),
-                        'installationInternalId' => $function->getAttribute('installationInternalId', ''),
-                        'projectId' => $project->getId(),
-                        'projectInternalId' => $project->getInternalId(),
-                        'providerRepositoryId' => $function->getAttribute('providerRepositoryId', ''),
-                        'resourceId' => $function->getId(),
-                        'resourceInternalId' => $function->getInternalId(),
-                        'resourceType' => 'function',
-                        'providerPullRequestIds' => []
-                    ]));
-
-                    $function = $dbForProject->updateDocument('functions', $function->getId(), $function
-                        ->setAttribute('repositoryId', $repository->getId())
-                        ->setAttribute('repositoryInternalId', $repository->getInternalId()));
-
-                    $this->foreachDocument($dbForProject, 'deployments', [
-                        Query::equal('resourceInternalId', [$function->getInternalId()]),
-                        Query::equal('resourceType', ['functions'])
-                    ], function (Document $deployment) use ($dbForProject, $repository) {
-                        $dbForProject->updateDocument('deployments', $deployment->getId(), $deployment
-                            ->setAttribute('repositoryId', $repository->getId())
-                            ->setAttribute('repositoryInternalId', $repository->getInternalId()));
-                    });
-                }
-            }
-        });
-    }
-}
diff --git a/src/Appwrite/Platform/Tasks/QueueCount.php b/src/Appwrite/Platform/Tasks/QueueCount.php
index 9b7bba82d1..97fd602037 100644
--- a/src/Appwrite/Platform/Tasks/QueueCount.php
+++ b/src/Appwrite/Platform/Tasks/QueueCount.php
@@ -7,6 +7,7 @@ use Utopia\CLI\Console;
 use Utopia\Platform\Action;
 use Utopia\Queue\Client;
 use Utopia\Queue\Connection;
+use Utopia\Validator\Text;
 use Utopia\Validator\WhiteList;
 
 class QueueCount extends Action
@@ -21,20 +22,7 @@ class QueueCount extends Action
     {
         $this
             ->desc('Return the number of from a specific queue identified by the name parameter with a specific type')
-            ->param('name', '', new WhiteList([
-                Event::DATABASE_QUEUE_NAME,
-                Event::DELETE_QUEUE_NAME,
-                Event::AUDITS_QUEUE_NAME,
-                Event::MAILS_QUEUE_NAME,
-                Event::FUNCTIONS_QUEUE_NAME,
-                Event::USAGE_QUEUE_NAME,
-                Event::WEBHOOK_QUEUE_NAME,
-                Event::CERTIFICATES_QUEUE_NAME,
-                Event::BUILDS_QUEUE_NAME,
-                Event::MESSAGING_QUEUE_NAME,
-                Event::MIGRATIONS_QUEUE_NAME,
-                Event::HAMSTER_QUEUE_NAME
-            ]), 'Queue name')
+            ->param('name', '', new Text(100), 'Queue name')
             ->param('type', '', new WhiteList([
                 'success',
                 'failed',
diff --git a/src/Appwrite/Platform/Tasks/QueueRetry.php b/src/Appwrite/Platform/Tasks/QueueRetry.php
index 2781d9a3f7..5cd0a87ff8 100644
--- a/src/Appwrite/Platform/Tasks/QueueRetry.php
+++ b/src/Appwrite/Platform/Tasks/QueueRetry.php
@@ -8,6 +8,7 @@ use Utopia\Platform\Action;
 use Utopia\Queue\Client;
 use Utopia\Queue\Connection;
 use Utopia\Validator\Integer;
+use Utopia\Validator\Text;
 use Utopia\Validator\WhiteList;
 use Utopia\Validator\Wildcard;
 
@@ -23,20 +24,7 @@ class QueueRetry extends Action
     {
         $this
             ->desc('Retry failed jobs from a specific queue identified by the name parameter')
-            ->param('name', '', new WhiteList([
-                Event::DATABASE_QUEUE_NAME,
-                Event::DELETE_QUEUE_NAME,
-                Event::AUDITS_QUEUE_NAME,
-                Event::MAILS_QUEUE_NAME,
-                Event::FUNCTIONS_QUEUE_NAME,
-                Event::USAGE_QUEUE_NAME,
-                Event::WEBHOOK_CLASS_NAME,
-                Event::CERTIFICATES_QUEUE_NAME,
-                Event::BUILDS_QUEUE_NAME,
-                Event::MESSAGING_QUEUE_NAME,
-                Event::MIGRATIONS_QUEUE_NAME,
-                Event::HAMSTER_CLASS_NAME
-            ]), 'Queue name')
+            ->param('name', '', new Text(100), 'Queue name')
             ->param('limit', 0, new Wildcard(), 'jobs limit', true)
             ->inject('queue')
             ->callback(fn ($name, $limit, $queue) => $this->action($name, $limit, $queue));
diff --git a/src/Appwrite/Platform/Tasks/SDKs.php b/src/Appwrite/Platform/Tasks/SDKs.php
index 256b36d885..068da7c68e 100644
--- a/src/Appwrite/Platform/Tasks/SDKs.php
+++ b/src/Appwrite/Platform/Tasks/SDKs.php
@@ -74,7 +74,7 @@ class SDKs extends Action
 
                 $spec = file_get_contents(__DIR__ . '/../../../../app/config/specs/swagger2-' . $version . '-' . $language['family'] . '.json');
 
-                $cover = 'https://appwrite.io/images/github.png';
+                $cover = 'https://github.com/appwrite/appwrite/raw/main/public/images/github.png';
                 $result = \realpath(__DIR__ . '/../../../../app') . '/sdks/' . $key . '-' . $language['key'];
                 $resultExamples = \realpath(__DIR__ . '/../../../..') . '/docs/examples/' . $version . '/' . $key . '-' . $language['key'];
                 $target = \realpath(__DIR__ . '/../../../../app') . '/sdks/git/' . $language['key'] . '/';
diff --git a/src/Appwrite/Platform/Tasks/VolumeSync.php b/src/Appwrite/Platform/Tasks/VolumeSync.php
deleted file mode 100644
index 6197b20fbd..0000000000
--- a/src/Appwrite/Platform/Tasks/VolumeSync.php
+++ /dev/null
@@ -1,59 +0,0 @@
-<?php
-
-namespace Appwrite\Platform\Tasks;
-
-use Utopia\CLI\Console;
-use Utopia\Database\DateTime;
-use Utopia\Platform\Action;
-use Utopia\Validator\Integer;
-use Utopia\Validator\Text;
-
-class VolumeSync extends Action
-{
-    public static function getName(): string
-    {
-        return 'volume-sync';
-    }
-
-    public function __construct()
-    {
-        $this
-            ->desc('Runs rsync to sync certificates between the storage mount and traefik.')
-            ->param('source', null, new Text(255), 'Source path to sync from.', false)
-            ->param('destination', null, new Text(255), 'Destination path to sync to.', false)
-            ->param('interval', null, new Integer(true), 'Interval to run rsync', false)
-            ->callback(fn ($source, $destination, $interval) => $this->action($source, $destination, $interval));
-    }
-
-    public function action(string $source, string $destination, int $interval)
-    {
-
-        Console::title('RSync V1');
-        Console::success(APP_NAME . ' rsync process v1 has started');
-
-        if (!file_exists($source)) {
-            Console::error('Source directory does not exist. Exiting ... ');
-            Console::exit(0);
-        }
-
-        Console::loop(function () use ($interval, $source, $destination) {
-            $time = DateTime::now();
-
-            Console::info("[{$time}] Executing rsync every {$interval} seconds");
-            Console::info("Syncing between $source and $destination");
-
-            if (!file_exists($source)) {
-                Console::error('Source directory does not exist. Skipping ... ');
-                return;
-            }
-
-            $stdin = "";
-            $stdout = "";
-            $stderr = "";
-
-            Console::execute("rsync -av $source $destination", $stdin, $stdout, $stderr);
-            Console::success($stdout);
-            Console::error($stderr);
-        }, $interval);
-    }
-}
diff --git a/src/Appwrite/Platform/Workers/Functions.php b/src/Appwrite/Platform/Workers/Functions.php
index bde5644ade..2ae644a24e 100644
--- a/src/Appwrite/Platform/Workers/Functions.php
+++ b/src/Appwrite/Platform/Workers/Functions.php
@@ -194,6 +194,70 @@ class Functions extends Action
         }
     }
 
+    /**
+     * @param string $message
+     * @param Document $function
+     * @param string $trigger
+     * @param string $path
+     * @param string $method
+     * @param Document $user
+     * @param string|null $jwt
+     * @param string|null $event
+     * @throws Exception
+     */
+    private function fail(
+        string $message,
+        Database $dbForProject,
+        Document $function,
+        string $trigger,
+        string $path,
+        string $method,
+        Document $user,
+        string $jwt = null,
+        string $event = null,
+    ): void {
+        $headers['x-appwrite-trigger'] = $trigger;
+        $headers['x-appwrite-event'] = $event ?? '';
+        $headers['x-appwrite-user-id'] = $user->getId() ?? '';
+        $headers['x-appwrite-user-jwt'] = $jwt ?? '';
+
+        $headersFiltered = [];
+        foreach ($headers as $key => $value) {
+            if (\in_array(\strtolower($key), FUNCTION_ALLOWLIST_HEADERS_REQUEST)) {
+                $headersFiltered[] = ['name' => $key, 'value' => $value];
+            }
+        }
+
+        $executionId = ID::unique();
+        $execution = new Document([
+            '$id' => $executionId,
+            '$permissions' => $user->isEmpty() ? [] : [Permission::read(Role::user($user->getId()))],
+            'functionInternalId' => $function->getInternalId(),
+            'functionId' => $function->getId(),
+            'deploymentInternalId' => '',
+            'deploymentId' => '',
+            'trigger' => $trigger,
+            'status' => 'failed',
+            'responseStatusCode' => 0,
+            'responseHeaders' => [],
+            'requestPath' => $path,
+            'requestMethod' => $method,
+            'requestHeaders' => $headersFiltered,
+            'errors' => $message,
+            'logs' => '',
+            'duration' => 0.0,
+            'search' => implode(' ', [$function->getId(), $executionId]),
+        ]);
+
+        if ($function->getAttribute('logging')) {
+            $execution = $dbForProject->createDocument('executions', $execution);
+        }
+
+        if ($execution->isEmpty()) {
+            throw new Exception('Failed to create execution');
+        }
+    }
+
     /**
      * @param Log $log
      * @param Database $dbForProject
@@ -248,24 +312,32 @@ class Functions extends Action
             $deployment = $dbForProject->getDocument('deployments', $deploymentId);
 
         if ($deployment->getAttribute('resourceId') !== $functionId) {
-            throw new Exception('Deployment not found. Create deployment before trying to execute a function');
+            $errorMessage = 'The execution could not be completed because a corresponding deployment was not found. A function deployment needs to be created before it can be executed. Please create a deployment for your function and try again.';
+            $this->fail($errorMessage, $dbForProject, $function, $trigger, $path, $method, $user, $jwt, $event);
+            return;
         }
 
         if ($deployment->isEmpty()) {
-            throw new Exception('Deployment not found. Create deployment before trying to execute a function');
+            $errorMessage = 'The execution could not be completed because a corresponding deployment was not found. A function deployment needs to be created before it can be executed. Please create a deployment for your function and try again.';
+            $this->fail($errorMessage, $dbForProject, $function, $trigger, $path, $method, $user, $jwt, $event);
+            return;
         }
 
-            /** Check if build has exists */
-            $build = $dbForProject->getDocument('builds', $deployment->getAttribute('buildId', ''));
+        /** Check if the build exists */
+        $build = $dbForProject->getDocument('builds', $deployment->getAttribute('buildId', ''));
         if ($build->isEmpty()) {
-            throw new Exception('Build not found');
+            $errorMessage = 'The execution could not be completed because a corresponding deployment was not found. A function deployment needs to be created before it can be executed. Please create a deployment for your function and try again.';
+            $this->fail($errorMessage, $dbForProject, $function, $trigger, $path, $method, $user, $jwt, $event);
+            return;
         }
 
         if ($build->getAttribute('status') !== 'ready') {
-            throw new Exception('Build not ready');
+            $errorMessage = 'The execution could not be completed because the build is not ready. Please wait for the build to complete and try again.';
+            $this->fail($errorMessage, $dbForProject, $function, $trigger, $path, $method, $user, $jwt, $event);
+            return;
         }
 
-            /** Check if  runtime is supported */
+        /** Check if  runtime is supported */
         $version = $function->getAttribute('version', 'v2');
         $runtimes = Config::getParam($version === 'v2' ? 'runtimes-v2' : 'runtimes', []);
 
@@ -280,7 +352,6 @@ class Functions extends Action
         $headers['x-appwrite-user-id'] = $user->getId() ?? '';
         $headers['x-appwrite-user-jwt'] = $jwt ?? '';
 
-        /** Create execution or update execution status */
         /** Create execution or update execution status */
         $execution = $dbForProject->getDocument('executions', $executionId ?? '');
         if ($execution->isEmpty()) {
diff --git a/src/Appwrite/Platform/Workers/Hamster.php b/src/Appwrite/Platform/Workers/Hamster.php
deleted file mode 100644
index 0fb705d0f7..0000000000
--- a/src/Appwrite/Platform/Workers/Hamster.php
+++ /dev/null
@@ -1,495 +0,0 @@
-<?php
-
-namespace Appwrite\Platform\Workers;
-
-use Appwrite\Event\Hamster as EventHamster;
-use Appwrite\Network\Validator\Origin;
-use Utopia\Analytics\Adapter\Mixpanel;
-use Utopia\Analytics\Event as AnalyticsEvent;
-use Utopia\App;
-use Utopia\Cache\Cache;
-use Utopia\CLI\Console;
-use Utopia\Config\Config;
-use Utopia\Platform\Action;
-use Utopia\Database\Database;
-use Utopia\Database\Query;
-use Utopia\Database\Validator\Authorization;
-use Utopia\Database\Document;
-use Utopia\Queue\Message;
-use Utopia\Logger\Log;
-use Utopia\Pools\Group;
-
-class Hamster extends Action
-{
-    private array $metrics = [
-        'usage_files' => 'files',
-        'usage_buckets' => 'buckets',
-        'usage_databases' => 'databases',
-        'usage_documents' => 'documents',
-        'usage_collections' => 'collections',
-        'usage_storage' => 'files.storage',
-        'usage_requests' => 'network.requests',
-        'usage_inbound' => 'network.inbound',
-        'usage_outbound' => 'network.outbound',
-        'usage_users' => 'users',
-        'usage_sessions' => 'sessions',
-        'usage_executions' => 'executions',
-    ];
-
-    protected Mixpanel $mixpanel;
-
-    public static function getName(): string
-    {
-        return 'hamster';
-    }
-
-    /**
-     * @throws \Exception
-     */
-    public function __construct()
-    {
-        $this
-            ->desc('Hamster worker')
-            ->inject('message')
-            ->inject('pools')
-            ->inject('cache')
-            ->inject('dbForConsole')
-            ->callback(fn (Message $message, Group $pools, Cache $cache, Database $dbForConsole) => $this->action($message, $pools, $cache, $dbForConsole));
-    }
-
-    /**
-     * @param Message $message
-     * @param Group $pools
-     * @param Cache $cache
-     * @param Database $dbForConsole
-     *
-     * @return void
-     * @throws \Utopia\Database\Exception
-     */
-    public function action(Message $message, Group $pools, Cache $cache, Database $dbForConsole): void
-    {
-        $token = App::getEnv('_APP_MIXPANEL_TOKEN', '');
-        if (empty($token)) {
-            throw new \Exception('Missing MixPanel Token');
-        }
-        $this->mixpanel = new Mixpanel($token);
-
-        $payload = $message->getPayload() ?? [];
-
-        if (empty($payload)) {
-            throw new \Exception('Missing payload');
-        }
-
-        $type = $payload['type'] ?? '';
-
-        switch ($type) {
-            case EventHamster::TYPE_PROJECT:
-                $this->getStatsForProject(new Document($payload['project']), $pools, $cache, $dbForConsole);
-                break;
-            case EventHamster::TYPE_ORGANISATION:
-                $this->getStatsForOrganization(new Document($payload['organization']), $dbForConsole);
-                break;
-            case EventHamster::TYPE_USER:
-                $this->getStatsPerUser(new Document($payload['user']), $dbForConsole);
-                break;
-        }
-    }
-
-    /**
-     * @param Document $project
-     * @param Group $pools
-     * @param Cache $cache
-     * @param Database $dbForConsole
-     * @throws \Utopia\Database\Exception
-     */
-    private function getStatsForProject(Document $project, Group $pools, Cache $cache, Database $dbForConsole): void
-    {
-        /**
-         * Skip user projects with id 'console'
-         */
-        if ($project->getId() === 'console') {
-            Console::info("Skipping project console");
-            return;
-        }
-
-        Console::log("Getting stats for Project {$project->getId()}");
-
-        try {
-            $db = $project->getAttribute('database');
-            $adapter = $pools
-                ->get($db)
-                ->pop()
-                ->getResource();
-
-            $dbForProject = new Database($adapter, $cache);
-            $dbForProject->setDefaultDatabase('appwrite');
-            $dbForProject->setNamespace('_' . $project->getInternalId());
-
-            $statsPerProject = [];
-
-            $statsPerProject['time'] = $project->getAttribute('$time');
-
-            /** Get Project ID */
-            $statsPerProject['project_id'] = $project->getId();
-
-            /** Get project created time */
-            $statsPerProject['project_created'] = $project->getAttribute('$createdAt');
-
-            /** Get Project Name */
-            $statsPerProject['project_name'] = $project->getAttribute('name');
-
-            /** Total Project Variables */
-            $statsPerProject['custom_variables'] = $dbForProject->count('variables', [], APP_LIMIT_COUNT);
-
-            /** Total Migrations */
-            $statsPerProject['custom_migrations'] = $dbForProject->count('migrations', [], APP_LIMIT_COUNT);
-
-            /** Get Custom SMTP */
-            $smtp = $project->getAttribute('smtp', null);
-            if ($smtp) {
-                $statsPerProject['custom_smtp_status'] = $smtp['enabled'] === true ? 'enabled' : 'disabled';
-
-                /** Get Custom Templates Count */
-                $templates = array_keys($project->getAttribute('templates', []));
-                $statsPerProject['custom_email_templates'] = array_filter($templates, function ($template) {
-                    return str_contains($template, 'email');
-                });
-                $statsPerProject['custom_sms_templates'] = array_filter($templates, function ($template) {
-                    return str_contains($template, 'sms');
-                });
-            }
-
-            /** Get total relationship attributes */
-            $statsPerProject['custom_relationship_attributes'] = $dbForProject->count('attributes', [
-                Query::equal('type', ['relationship'])
-            ], APP_LIMIT_COUNT);
-
-            /** Get Total Functions */
-            $statsPerProject['custom_functions'] = $dbForProject->count('functions', [], APP_LIMIT_COUNT);
-
-            foreach (\array_keys(Config::getParam('runtimes')) as $runtime) {
-                $statsPerProject['custom_functions_' . $runtime] = $dbForProject->count('functions', [
-                    Query::equal('runtime', [$runtime]),
-                ], APP_LIMIT_COUNT);
-            }
-
-            /** Get Total Deployments */
-            $statsPerProject['custom_deployments'] = $dbForProject->count('deployments', [], APP_LIMIT_COUNT);
-            $statsPerProject['custom_deployments_manual'] = $dbForProject->count('deployments', [
-                Query::equal('type', ['manual'])
-            ], APP_LIMIT_COUNT);
-            $statsPerProject['custom_deployments_git'] = $dbForProject->count('deployments', [
-                Query::equal('type', ['vcs'])
-            ], APP_LIMIT_COUNT);
-
-            /** Get VCS repos connected */
-            $statsPerProject['custom_vcs_repositories'] = $dbForConsole->count('repositories', [
-                Query::equal('projectInternalId', [$project->getInternalId()])
-            ], APP_LIMIT_COUNT);
-
-            /** Get Total Teams */
-            $statsPerProject['custom_teams'] = $dbForProject->count('teams', [], APP_LIMIT_COUNT);
-
-            /** Get Total Members */
-            $teamInternalId = $project->getAttribute('teamInternalId', null);
-            if ($teamInternalId) {
-                $statsPerProject['custom_organization_members'] = $dbForConsole->count('memberships', [
-                    Query::equal('teamInternalId', [$teamInternalId])
-                ], APP_LIMIT_COUNT);
-            } else {
-                $statsPerProject['custom_organization_members'] = 0;
-            }
-
-            /** Get Email and Name of the project owner */
-            if ($teamInternalId) {
-                $membership = $dbForConsole->findOne('memberships', [
-                    Query::equal('teamInternalId', [$teamInternalId]),
-                ]);
-
-                if (!$membership || $membership->isEmpty()) {
-                    throw new \Exception('Membership not found. Skipping project : ' . $project->getId());
-                }
-
-                $userId = $membership->getAttribute('userId', null);
-                if ($userId) {
-                    $user = $dbForConsole->getDocument('users', $userId);
-                    $statsPerProject['email'] = $user->getAttribute('email', null);
-                    $statsPerProject['name'] = $user->getAttribute('name', null);
-                }
-            }
-
-            /** Add billing information to the project */
-            $organization = $dbForConsole->findOne('teams', [
-                Query::equal('$internalId', [$teamInternalId])
-            ]);
-
-            $billing = $this->getBillingDetails($organization);
-            $statsPerProject['billing_plan'] = $billing['billing_plan'] ?? null;
-            $statsPerProject['billing_start_date'] = $billing['billing_start_date'] ?? null;
-
-            /** Get Domains */
-            $statsPerProject['custom_domains'] = $dbForConsole->count('rules', [
-                Query::equal('projectInternalId', [$project->getInternalId()]),
-                Query::limit(APP_LIMIT_COUNT)
-            ]);
-
-            /** Get Platforms */
-            $platforms = $dbForConsole->find('platforms', [
-                Query::equal('projectInternalId', [$project->getInternalId()]),
-                Query::limit(APP_LIMIT_COUNT)
-            ]);
-
-            $statsPerProject['custom_platforms_web'] = sizeof(array_filter($platforms, function ($platform) {
-                return $platform['type'] === 'web';
-            }));
-
-            $statsPerProject['custom_platforms_android'] = sizeof(array_filter($platforms, function ($platform) {
-                return $platform['type'] === 'android';
-            }));
-
-            $statsPerProject['custom_platforms_apple'] = sizeof(array_filter($platforms, function ($platform) {
-                return str_contains($platform['type'], 'apple');
-            }));
-
-            $statsPerProject['custom_platforms_flutter'] = sizeof(array_filter($platforms, function ($platform) {
-                return str_contains($platform['type'], 'flutter');
-            }));
-
-            $flutterPlatforms = [Origin::CLIENT_TYPE_FLUTTER_ANDROID, Origin::CLIENT_TYPE_FLUTTER_IOS, Origin::CLIENT_TYPE_FLUTTER_MACOS, Origin::CLIENT_TYPE_FLUTTER_WINDOWS, Origin::CLIENT_TYPE_FLUTTER_LINUX];
-
-            foreach ($flutterPlatforms as $flutterPlatform) {
-                $statsPerProject['custom_platforms_' . $flutterPlatform] = sizeof(array_filter($platforms, function ($platform) use ($flutterPlatform) {
-                    return $platform['type'] === $flutterPlatform;
-                }));
-            }
-
-            $statsPerProject['custom_platforms_api_keys'] = $dbForConsole->count('keys', [
-                Query::equal('projectInternalId', [$project->getInternalId()]),
-                Query::limit(APP_LIMIT_COUNT)
-            ]);
-
-            /** Get Usage $statsPerProject */
-            $periods = [
-                'infinity' => [
-                    'period' => '1d',
-                    'limit' => 90,
-                ],
-                '24h' => [
-                    'period' => '1h',
-                    'limit' => 24,
-                ],
-            ];
-
-            Authorization::skip(function () use ($dbForProject, $periods, &$statsPerProject) {
-                foreach ($this->metrics as $key => $metric) {
-                    foreach ($periods as $periodKey => $periodValue) {
-                        $limit = $periodValue['limit'];
-                        $period = $periodValue['period'];
-
-                        $requestDocs = $dbForProject->find('stats_v2', [
-                            Query::equal('period', [$period]),
-                            Query::equal('metric', [$metric]),
-                            Query::limit($limit),
-                            Query::orderDesc('time'),
-                        ]);
-
-                        $statsPerProject[$key . '_' . $periodKey] = [];
-                        foreach ($requestDocs as $requestDoc) {
-                            $statsPerProject[$key . '_' . $periodKey][] = [
-                                'value' => $requestDoc->getAttribute('value'),
-                                'date' => $requestDoc->getAttribute('time'),
-                            ];
-                        }
-
-                        $statsPerProject[$key . '_' . $periodKey] = array_reverse($statsPerProject[$key . '_' . $periodKey]);
-                        // Calculate aggregate of each metric
-                        $statsPerProject[$key . '_' . $periodKey] = array_sum(array_column($statsPerProject[$key . '_' . $periodKey], 'value'));
-                    }
-                }
-            });
-
-            /**
-             * Workaround to combine network.Inbound+network.outbound as bandwidth.
-             */
-            $statsPerProject["usage_bandwidth_infinity"]  = $statsPerProject["usage_inbound_infinity"] + $statsPerProject["usage_outbound_infinity"];
-            $statsPerProject["usage_bandwidth_24h"]  = $statsPerProject["usage_inbound_24h"] + $statsPerProject["usage_outbound_24h"];
-            unset($statsPerProject["usage_outbound_24h"]);
-            unset($statsPerProject["usage_inbound_24h"]);
-            unset($statsPerProject["usage_outbound_infinity"]);
-            unset($statsPerProject["usage_inbound_infinity"]);
-
-
-            if (isset($statsPerProject['email'])) {
-                /** Send data to mixpanel */
-                $res = $this->mixpanel->createProfile($statsPerProject['email'], '', [
-                    'name' => $statsPerProject['name'],
-                    'email' => $statsPerProject['email']
-                ]);
-
-                if (!$res) {
-                    Console::error('Failed to create user profile for project: ' . $project->getId());
-                }
-            }
-
-            $event = new AnalyticsEvent();
-            $event
-                ->setName('Project Daily Usage')
-                ->setProps($statsPerProject);
-            $res = $this->mixpanel->createEvent($event);
-
-            if (!$res) {
-                Console::error('Failed to create event for project: ' . $project->getId());
-            }
-        } catch (\Exception $e) {
-            Console::error('Failed to send stats for project: ' . $project->getId());
-            Console::error($e->getMessage());
-        } finally {
-            $pools
-                ->get($db)
-                ->reclaim();
-        }
-    }
-
-    /**
-     * @param Document $organization
-     * @param Database $dbForConsole
-     */
-    private function getStatsForOrganization(Document $organization, Database $dbForConsole): void
-    {
-        Console::log("Getting stats for Organization {$organization->getId()}");
-
-        try {
-            $statsPerOrganization = [];
-
-            $statsPerOrganization['time'] = $organization->getAttribute('$time');
-
-            /** Organization name */
-            $statsPerOrganization['name'] = $organization->getAttribute('name');
-
-            /** Get Email and of the organization owner */
-            $membership = $dbForConsole->findOne('memberships', [
-                Query::equal('teamInternalId', [$organization->getInternalId()]),
-            ]);
-            if (!$membership || $membership->isEmpty()) {
-                throw new \Exception('Membership not found. Skipping organization : ' . $organization->getId());
-            }
-            $userId = $membership->getAttribute('userId', null);
-            if ($userId) {
-                $user = $dbForConsole->getDocument('users', $userId);
-                $statsPerOrganization['email'] = $user->getAttribute('email', null);
-            }
-
-            /** Add billing information */
-            $billing = $this->getBillingDetails($organization);
-            $statsPerOrganization['billing_plan'] = $billing['billing_plan'] ?? null;
-            $statsPerOrganization['billing_start_date'] = $billing['billing_start_date'] ?? null;
-            $statsPerOrganization['marked_for_deletion'] = $billing['markedForDeletion'] ?? 0;
-            $statsPerOrganization['billing_plan_downgrade'] = $billing['billing_plan_downgrade'] ?? null;
-
-            /** Organization Creation Date */
-            $statsPerOrganization['created'] = $organization->getAttribute('$createdAt');
-
-            /** Number of team members */
-            $statsPerOrganization['members'] = $organization->getAttribute('total');
-
-            /** Number of projects in this organization */
-            $statsPerOrganization['projects'] = $dbForConsole->count('projects', [
-                Query::equal('teamId', [$organization->getId()]),
-                Query::limit(APP_LIMIT_COUNT)
-            ]);
-
-            if (!isset($statsPerOrganization['email'])) {
-                throw new \Exception('Email not found. Skipping organization : ' . $organization->getId());
-            }
-
-            $event = new AnalyticsEvent();
-            $event
-                ->setName('Organization Daily Usage')
-                ->setProps($statsPerOrganization);
-            $res = $this->mixpanel->createEvent($event);
-            if (!$res) {
-                throw new \Exception('Failed to create event for organization : ' . $organization->getId());
-            }
-        } catch (\Exception $e) {
-            Console::error($e->getMessage());
-        }
-    }
-
-    protected function getStatsPerUser(Document $user, Database $dbForConsole)
-    {
-        Console::log("Getting stats for User {$user->getId()}");
-
-        try {
-            $statsPerUser = [];
-
-            $statsPerUser['time'] = $user->getAttribute('$time');
-
-            /** Add billing information */
-            $organization = $dbForConsole->findOne('teams', [
-                Query::equal('userInternalId', [$user->getInternalId()])
-            ]);
-
-
-            $billing = $this->getBillingDetails($organization);
-            $statsPerUser['billing_plan'] = $billing['billing_plan'] ?? null;
-            $statsPerUser['billing_start_date'] = $billing['billing_start_date'] ?? null;
-
-            /** Organization name */
-            $statsPerUser['name'] = $user->getAttribute('name');
-
-            /** Organization ID (needs to be stored as an email since mixpanel uses the email attribute as a distinctID) */
-            $statsPerUser['email'] = $user->getAttribute('email');
-
-            /** Organization Creation Date */
-            $statsPerUser['created'] = $user->getAttribute('$createdAt');
-
-            /** Number of teams this user is a part of */
-            $statsPerUser['memberships'] = $dbForConsole->count('memberships', [
-                Query::equal('userInternalId', [$user->getInternalId()]),
-                Query::limit(APP_LIMIT_COUNT)
-            ]);
-
-            if (!isset($statsPerUser['email'])) {
-                throw new \Exception('User has no email: ' . $user->getId());
-            }
-
-            /** Send data to mixpanel */
-            $event = new AnalyticsEvent();
-            $event
-                ->setName('User Daily Usage')
-                ->setProps($statsPerUser);
-
-            $res = $this->mixpanel->createEvent($event);
-
-            if (!$res) {
-                throw new \Exception('Failed to create user profile for user: ' . $user->getId());
-            }
-        } catch (\Exception $e) {
-            Console::error($e->getMessage());
-        }
-    }
-
-    private function getBillingDetails(bool|Document $team): array
-    {
-        $billing = [];
-
-        if (!empty($team) && !$team->isEmpty()) {
-            $billingPlan = $team->getAttribute('billingPlan', null);
-            $billingPlanDowngrade = $team->getAttribute('billingPlanDowngrade', null);
-
-            if (!empty($billingPlan) && empty($billingPlanDowngrade)) {
-                $billing['billing_plan'] = $billingPlan;
-            }
-
-            if (in_array($billingPlan, ['tier-1', 'tier-2'])) {
-                $billingStartDate = $team->getAttribute('billingStartDate', null);
-                $billing['billing_start_date'] = $billingStartDate;
-            }
-
-            $billing['marked_for_deletion'] = $team->getAttribute('markedForDeletion', 0);
-            $billing['billing_plan_downgrade'] = $billingPlanDowngrade;
-        }
-
-        return $billing;
-    }
-}
diff --git a/src/Appwrite/Vcs/Comment.php b/src/Appwrite/Vcs/Comment.php
index 1107e0ee70..55e11ec790 100644
--- a/src/Appwrite/Vcs/Comment.php
+++ b/src/Appwrite/Vcs/Comment.php
@@ -2,8 +2,8 @@
 
 namespace Appwrite\Vcs;
 
-use Utopia\Database\Document;
 use Utopia\App;
+use Utopia\Database\Document;
 
 class Comment
 {
@@ -65,18 +65,23 @@ class Comment
             ];
         }
 
-        //TODO: Update link to documentation
-        $text .= "**Your function has been automatically deployed.** Learn more about Appwrite [Function Deployments](https://appwrite.io/docs/functions).\n\n";
-
         foreach ($projects as $projectId => $project) {
-            $text .= "**{$project['name']}** `{$projectId}`\n\n";
-            $text .= "| Function | ID | Status | Action |\n";
-            $text .= "| :- | :-  | :-  | :- |\n";
-
-            $protocol = App::getEnv('_APP_OPTIONS_FORCE_HTTPS') == 'disabled' ? 'http' : 'https';
-            $hostname = App::getEnv('_APP_DOMAIN');
-
             foreach ($project['functions'] as $functionId => $function) {
+                if ($function['status'] === 'waiting' || $function['status'] === 'processing' || $function['status'] === 'building') {
+                    $text .= "**Your function deployment is in progress. Please check back in a few minutes for the updated status.**\n\n";
+                } elseif ($function['status'] === 'ready') {
+                    $text .= "**Your function has been successfully deployed.**\n\n";
+                } else {
+                    $text .= "**Your function deployment has failed. Please check the logs for more details and retry.**\n\n";
+                }
+
+                $text .= "Project name: **{$project['name']}** \nProject ID: `{$projectId}`\n\n";
+                $text .= "| Function | ID | Status | Action |\n";
+                $text .= "| :- | :-  | :-  | :- |\n";
+
+                $protocol = App::getEnv('_APP_OPTIONS_FORCE_HTTPS') == 'disabled' ? 'http' : 'https';
+                $hostname = App::getEnv('_APP_DOMAIN');
+
                 $generateImage = function (string $status) use ($protocol, $hostname) {
                     $extention = $status === 'building' ? 'gif' : 'png';
                     $imagesUrl = $protocol . '://' . $hostname . '/images/vcs/';
@@ -104,7 +109,9 @@ class Comment
 
             $text .= "\n\n";
         }
-        //TODO: Update did you know section
+        $functionUrl = $protocol . '://' . $hostname . '/console/project-' . $projectId . '/functions/function-' . $functionId;
+        $text .= "Only deployments on the production branch are activated automatically. If you'd like to activate this deployment, navigate to [your deployments]($functionUrl). Learn more about Appwrite [Function deployments](https://appwrite.io/docs/functions).\n\n";
+
         $tip = $this->tips[array_rand($this->tips)];
         $text .= "> **💡 Did you know?** \n " . $tip . "\n\n";
 
diff --git a/tests/e2e/Services/Console/ModeTest.php b/tests/e2e/Services/Console/ModeTest.php
new file mode 100644
index 0000000000..0345b076a6
--- /dev/null
+++ b/tests/e2e/Services/Console/ModeTest.php
@@ -0,0 +1,34 @@
+<?php
+
+namespace Tests\E2E\Services\Console;
+
+use Appwrite\Extend\Exception;
+use Tests\E2E\Client;
+use Tests\E2E\Scopes\ProjectConsole;
+use Tests\E2E\Scopes\Scope;
+use Tests\E2E\Scopes\SideClient;
+
+class ModeTest extends Scope
+{
+    use ProjectConsole;
+    use SideClient;
+
+    public function testConsoleWithAdminMode(): void
+    {
+        $this->markTestSkipped();
+
+        /**
+         * Test for SUCCESS
+         */
+        /*
+         $response = $this->client->call(Client::METHOD_GET, '/account', array_merge([
+             'content-type' => 'application/json',
+             'x-appwrite-project' => $this->getProject()['$id'],
+             'x-appwrite-mode' => 'admin',
+         ], $this->getHeaders()));
+
+         $this->assertEquals(400, $response['headers']['status-code']);
+         $this->assertEquals(Exception::GENERAL_BAD_REQUEST, $response['body']['type']);
+         */
+    }
+}
diff --git a/tests/e2e/Services/Databases/DatabasesBase.php b/tests/e2e/Services/Databases/DatabasesBase.php
index dbb6d795c6..c09f9a1cc1 100644
--- a/tests/e2e/Services/Databases/DatabasesBase.php
+++ b/tests/e2e/Services/Databases/DatabasesBase.php
@@ -4266,7 +4266,7 @@ trait DatabasesBase
             ], $this->getHeaders()), [
                 'documentId' => ID::unique(),
                 'data' => [
-                    'longtext' => file_get_contents('tests/resources/longtext.txt'),
+                    'longtext' => file_get_contents(__DIR__ . '/../../../resources/longtext.txt'),
                 ],
                 'permissions' => [
                     Permission::read(Role::user($this->getUser()['$id'])),
diff --git a/tests/e2e/Services/Locale/LocaleBase.php b/tests/e2e/Services/Locale/LocaleBase.php
index 17b5c66d67..872ec8449f 100644
--- a/tests/e2e/Services/Locale/LocaleBase.php
+++ b/tests/e2e/Services/Locale/LocaleBase.php
@@ -227,9 +227,9 @@ trait LocaleBase
         /**
          * Test for SUCCESS
          */
-        $languages           = require('app/config/locale/codes.php');
-        $defaultCountries    = require('app/config/locale/countries.php');
-        $defaultContinents   = require('app/config/locale/continents.php');
+        $languages           = require(__DIR__ . '/../../../../app/config/locale/codes.php');
+        $defaultCountries    = require(__DIR__ . '/../../../../app/config/locale/countries.php');
+        $defaultContinents   = require(__DIR__ . '/../../../../app/config/locale/continents.php');
 
         foreach ($languages as $lang) {
             $response = $this->client->call(Client::METHOD_GET, '/locale/countries', [
diff --git a/tests/e2e/Services/Projects/ProjectsConsoleClientTest.php b/tests/e2e/Services/Projects/ProjectsConsoleClientTest.php
index 574ff7dcc5..869e0c3582 100644
--- a/tests/e2e/Services/Projects/ProjectsConsoleClientTest.php
+++ b/tests/e2e/Services/Projects/ProjectsConsoleClientTest.php
@@ -798,7 +798,7 @@ class ProjectsConsoleClientTest extends Scope
     public function testUpdateProjectOAuth($data): array
     {
         $id = $data['projectId'] ?? '';
-        $providers = require('app/config/providers.php');
+        $providers = require(__DIR__ . '/../../../../app/config/providers.php');
 
         /**
          * Test for SUCCESS
@@ -909,7 +909,7 @@ class ProjectsConsoleClientTest extends Scope
     public function testUpdateProjectAuthStatus($data): array
     {
         $id = $data['projectId'] ?? '';
-        $auth = require('app/config/auth.php');
+        $auth = require(__DIR__ . '/../../../../app/config/auth.php');
 
         $originalEmail = uniqid() . 'user@localhost.test';
         $originalPassword = 'password';
@@ -1732,7 +1732,7 @@ class ProjectsConsoleClientTest extends Scope
         $this->assertNotEmpty($project['body']['$id']);
 
         $id = $project['body']['$id'];
-        $services = require('app/config/services.php');
+        $services = require(__DIR__ . '/../../../../app/config/services.php');
 
         /**
          * Test for Disabled
@@ -1806,7 +1806,7 @@ class ProjectsConsoleClientTest extends Scope
     {
         $id = $data['projectId'];
 
-        $services = require('app/config/services.php');
+        $services = require(__DIR__ . '/../../../../app/config/services.php');
 
         /**
          * Test for Disabled
@@ -1880,7 +1880,7 @@ class ProjectsConsoleClientTest extends Scope
     {
         $id = $data['projectId'];
 
-        $services = require('app/config/services.php');
+        $services = require(__DIR__ . '/../../../../app/config/services.php');
 
         /**
          * Test for Disabled
diff --git a/tests/unit/Event/EventTest.php b/tests/unit/Event/EventTest.php
index a430a7fdc6..d8ce60a35f 100644
--- a/tests/unit/Event/EventTest.php
+++ b/tests/unit/Event/EventTest.php
@@ -28,9 +28,9 @@ class EventTest extends TestCase
             'pass' => App::getEnv('_APP_REDIS_PASS', ''),
         ]);
 
-        $dsn = App::getEnv('_APP_CONNECTIONS_QUEUE', $fallbackForRedis);
+        $dsn = App::getEnv('_APP_CONNECTIONS_QUEUE', 'redis=' . $fallbackForRedis);
         $dsn = explode('=', $dsn);
-        $dsn = $dsn[0] ?? '';
+        $dsn = $dsn[1] ?? '';
         $dsn = new DSN($dsn);
         $connection = new Queue\Connection\Redis($dsn->getHost(), $dsn->getPort());
         $this->queue = 'v1-tests' . uniqid();