fix: Only dispatch from new engine in dev

adityachoudhari26 · adityachoudhari26 · commit 3ae0165c4657 · 2025-04-02T23:06:11.000-07:00
diff --git a/apps/event-worker/src/workers/policy-evaluate.ts b/apps/event-worker/src/workers/policy-evaluate.ts
@@ -1,3 +1,5 @@
+import { env } from "process";
+
 import { and, desc, eq, inArray, takeFirstOrNull } from "@ctrlplane/db";
 import { db } from "@ctrlplane/db/client";
 import * as schema from "@ctrlplane/db/schema";
@@ -116,7 +118,8 @@ export const policyEvaluateWorker = createWorker(
         return;
       }
 
-      getQueue(Channel.DispatchJob).add(dbJob.id, { jobId: dbJob.id });
+      if (env.NODE_ENV === "development")
+        getQueue(Channel.DispatchJob).add(dbJob.id, { jobId: dbJob.id });
     } finally {
       await mutex.unlock();
     }

Original file line number	Diff line number	Diff line change
`@@ -1,3 +1,5 @@`
	`1`	`+import { env } from "process";`
	`2`	`+`
`1`	`3`	`import { and, desc, eq, inArray, takeFirstOrNull } from "@ctrlplane/db";`
`2`	`4`	`import { db } from "@ctrlplane/db/client";`
`3`	`5`	`import * as schema from "@ctrlplane/db/schema";`
`@@ -116,7 +118,8 @@ export const policyEvaluateWorker = createWorker(`
`116`	`118`	`return;`
`117`	`119`	`}`
`118`	`120`
`119`		`- getQueue(Channel.DispatchJob).add(dbJob.id, { jobId: dbJob.id });`
	`121`	`+ if (env.NODE_ENV === "development")`
	`122`	`+ getQueue(Channel.DispatchJob).add(dbJob.id, { jobId: dbJob.id });`
`120`	`123`	`} finally {`
`121`	`124`	`await mutex.unlock();`
`122`	`125`	`}`