warn if dequeue interval > idle dequeue interval

nicktrn · nicktrn · commit f9c3f8242bf2 · 2025-05-16T02:50:04.000+01:00
diff --git a/apps/supervisor/src/index.ts b/apps/supervisor/src/index.ts
@@ -112,6 +112,12 @@ class ManagedSupervisor {
       }
     }
 
+    if (env.TRIGGER_DEQUEUE_INTERVAL_MS > env.TRIGGER_DEQUEUE_IDLE_INTERVAL_MS) {
+      this.logger.warn(
+        `⚠️  TRIGGER_DEQUEUE_INTERVAL_MS (${env.TRIGGER_DEQUEUE_INTERVAL_MS}) is greater than TRIGGER_DEQUEUE_IDLE_INTERVAL_MS (${env.TRIGGER_DEQUEUE_IDLE_INTERVAL_MS}) - did you mix them up?`
+      );
+    }
+
     this.workerSession = new SupervisorSession({
       workerToken: env.TRIGGER_WORKER_TOKEN,
       apiUrl: env.TRIGGER_API_URL,

Original file line number	Diff line number	Diff line change
`@@ -112,6 +112,12 @@ class ManagedSupervisor {`
`112`	`112`	`}`
`113`	`113`	`}`
`114`	`114`
	`115`	`+ if (env.TRIGGER_DEQUEUE_INTERVAL_MS > env.TRIGGER_DEQUEUE_IDLE_INTERVAL_MS) {`
	`116`	`+ this.logger.warn(`
	`117`	+ `⚠️ TRIGGER_DEQUEUE_INTERVAL_MS (${env.TRIGGER_DEQUEUE_INTERVAL_MS}) is greater than TRIGGER_DEQUEUE_IDLE_INTERVAL_MS (${env.TRIGGER_DEQUEUE_IDLE_INTERVAL_MS}) - did you mix them up?`
	`118`	`+ );`
	`119`	`+ }`
	`120`	`+`
`115`	`121`	`this.workerSession = new SupervisorSession({`
`116`	`122`	`workerToken: env.TRIGGER_WORKER_TOKEN,`
`117`	`123`	`apiUrl: env.TRIGGER_API_URL,`