From e38a4e43471c6fb12abd4d29d8bd2697542ebeb2 Mon Sep 17 00:00:00 2001
From: Chirag Aggarwal <chiragaggarwal5k@gmail.com>
Date: Thu, 19 Mar 2026 10:08:40 +0530
Subject: [PATCH] update queue

---
 app/init/worker/{job.php => message.php} | 2 +-
 app/worker.php                           | 5 ++---
 2 files changed, 3 insertions(+), 4 deletions(-)
 rename app/init/worker/{job.php => message.php} (99%)

diff --git a/app/init/worker/job.php b/app/init/worker/message.php
similarity index 99%
rename from app/init/worker/job.php
rename to app/init/worker/message.php
index a58d0c21ef..fbe99ea72e 100644
--- a/app/init/worker/job.php
+++ b/app/init/worker/message.php
@@ -39,7 +39,7 @@ use Utopia\Telemetry\Adapter as Telemetry;
  * These resources depend on the queue message or keep mutable state and
  * must be fresh for each worker job.
  */
-function registerWorkerJobResources(Container $container): void
+function registerWorkerMessageResources(Container $container): void
 {
     $container->set('log', fn () => new Log(), []);
 
diff --git a/app/worker.php b/app/worker.php
index 6500a6a570..2660052597 100644
--- a/app/worker.php
+++ b/app/worker.php
@@ -1,7 +1,7 @@
 <?php
 
 require_once __DIR__ . '/init.php';
-require_once __DIR__ . '/init/worker/job.php';
+require_once __DIR__ . '/init/worker/message.php';
 
 use Appwrite\Certificates\LetsEncrypt;
 use Appwrite\Platform\Appwrite;
@@ -90,10 +90,9 @@ try {
     );
 
     $worker = new Server($adapter, $container);
-    $worker->setCoroutines(true);
 
     $worker->init()->action(function () use ($worker) {
-        registerWorkerJobResources($worker->getContainer());
+        registerWorkerMessageResources($worker->getContainer());
     });
 
     $container->set('bus', function ($register) use ($worker) {