Update expireEnqueuedRun.server.ts

ericallam · ericallam · commit a7895b041277 · 2024-10-02T15:30:31.000-07:00
diff --git a/apps/webapp/app/v3/services/expireEnqueuedRun.server.ts b/apps/webapp/app/v3/services/expireEnqueuedRun.server.ts
@@ -14,7 +14,7 @@ export class ExpireEnqueuedRunService extends BaseService {
     return await workerQueue.enqueue(
       "v3.expireRun",
       { runId },
-      { runAt, jobKey: `v3.expireRun:${runId}` }
+      { runAt, jobKey: `v3.expireRun:${runId}`, tx }
     );
   }
 

Original file line number	Diff line number	Diff line change
`@@ -14,7 +14,7 @@ export class ExpireEnqueuedRunService extends BaseService {`
`14`	`14`	`return await workerQueue.enqueue(`
`15`	`15`	`"v3.expireRun",`
`16`	`16`	`{ runId },`
`17`		- { runAt, jobKey: `v3.expireRun:${runId}` }
	`17`	+ { runAt, jobKey: `v3.expireRun:${runId}`, tx }
`18`	`18`	`);`
`19`	`19`	`}`
`20`	`20`