fix: Setup job-execution-sync-worker (#6)

ctrlplanedev · Aug 30, 2024 · d736211 · d736211
1 parent 11f8875
commit d736211
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/apps/event-worker/src/index.ts b/apps/event-worker/src/index.ts
@@ -1,17 +1,21 @@
 import { logger } from "@ctrlplane/logger";
 
 import { createDispatchExecutionJobWorker } from "./job-execution-dispatch/index.js";
+import { createJobExecutionSyncWorker } from "./job-execution-sync/index.js";
 import { redis } from "./redis.js";
 import { createTargetScanWorker } from "./target-scan/index.js";
 
 const targetScanWorker = createTargetScanWorker();
+const jobExecutionSyncWorker = createJobExecutionSyncWorker();
 const dispatchExecutionJobWorker = createDispatchExecutionJobWorker();
 
 const shutdown = () => {
   logger.warn("Exiting...");
 
   targetScanWorker.close();
+  jobExecutionSyncWorker.close();
   dispatchExecutionJobWorker.close();
+
   redis.quit();
 
   process.exit(0);

diff --git a/apps/event-worker/src/job-execution-sync/index.ts b/apps/event-worker/src/job-execution-sync/index.ts
@@ -28,7 +28,7 @@ const getSyncFunction = (agentType: string): SyncFunction | null => {
   return null;
 };
 
-export const createJobExecutionSyncWorker = () => {
+export const createJobExecutionSyncWorker = () =>
   new Worker<DispatchJobExecutionEvent>(
     Channel.JobExecutionSync,
     (job) =>
@@ -62,4 +62,3 @@ export const createJobExecutionSyncWorker = () => {
       concurrency: 10,
     },
   );
-};