From effdeb4bc20c6cbab450f8eb1ebeb12497bc8a75 Mon Sep 17 00:00:00 2001 From: Jake Barnby Date: Thu, 12 Oct 2023 19:10:45 +1300 Subject: [PATCH] Fix env vars --- app/worker.php | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/app/worker.php b/app/worker.php index 5c95fa67b6..d646a70218 100644 --- a/app/worker.php +++ b/app/worker.php @@ -226,10 +226,10 @@ if (!empty($workerNum)) { try { $platform->init(Service::TYPE_WORKER, [ - 'workersNum' => str_starts_with(strtolower($workerName), 'databases') ? 1 : swoole_cpu_num() * intval(App::getEnv('_APP_WORKER_PER_CORE', 6)), + 'workersNum' => App::getEnv('_APP_WORKERS_NUM', swoole_cpu_num() * intval(App::getEnv('_APP_WORKER_PER_CORE', 6))), 'connection' => $pools->get('queue')->pop()->getResource(), 'workerName' => strtolower($workerName) ?? null, - 'queueName' => App::getEnv('_APP_CONNECTIONS_DB_QUEUE', 'database_db_main') + 'queueName' => App::getEnv('_APP_CONNECTIONS_DB_QUEUE', strtolower($workerName)) ]); } catch (\Exception $e) { Console::error($e->getMessage() . ', File: ' . $e->getFile() . ', Line: ' . $e->getLine());