Change how the run queue master queue consumers are disabled internally

Author: ericallam

apps/webapp/app/v3/runEngine.server.ts

@@ -63,6 +63,7 @@ function createRunEngine() {
       processWorkerQueueDebounceMs: env.RUN_ENGINE_PROCESS_WORKER_QUEUE_DEBOUNCE_MS,
       dequeueBlockingTimeoutSeconds: env.RUN_ENGINE_DEQUEUE_BLOCKING_TIMEOUT_SECONDS,
       masterQueueConsumersIntervalMs: env.RUN_ENGINE_MASTER_QUEUE_CONSUMERS_INTERVAL_MS,
+      masterQueueConsumersDisabled: env.RUN_ENGINE_WORKER_ENABLED === "0",
     },
     runLock: {
       redis: {

internal-packages/run-engine/src/engine/index.ts

@@ -123,7 +123,7 @@ export class RunEngine {
         shutdownTimeoutMs: options.worker.shutdownTimeoutMs,
       },
       shardCount: options.queue?.shardCount,
-      masterQueueConsumersDisabled: options.worker.disabled,
+      masterQueueConsumersDisabled: options.queue?.masterQueueConsumersDisabled,
       masterQueueConsumersIntervalMs: options.queue?.masterQueueConsumersIntervalMs,
       processWorkerQueueDebounceMs: options.queue?.processWorkerQueueDebounceMs,
       dequeueBlockingTimeoutSeconds: options.queue?.dequeueBlockingTimeoutSeconds,

internal-packages/run-engine/src/engine/types.ts

@@ -31,6 +31,7 @@ export type RunEngineOptions = {
   queue: {
     redis: RedisOptions;
     shardCount?: number;
+    masterQueueConsumersDisabled?: boolean;
     processWorkerQueueDebounceMs?: number;
     masterQueueConsumersIntervalMs?: number;
     workerOptions?: WorkerConcurrencyOptions;