update queue

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(), []);
 

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) {