From 7679febbdcfc7c6d551d8db97b94428572148b67 Mon Sep 17 00:00:00 2001 From: karishmas6 Date: Thu, 12 Sep 2024 19:42:02 +0530 Subject: [PATCH] fix: revert --- server/src/workflow-management/scheduler/index.ts | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/server/src/workflow-management/scheduler/index.ts b/server/src/workflow-management/scheduler/index.ts index 5f616b0e..2f81e7a2 100644 --- a/server/src/workflow-management/scheduler/index.ts +++ b/server/src/workflow-management/scheduler/index.ts @@ -28,7 +28,7 @@ const workflowQueue = new Queue('workflow', { connection }); export const worker = new Worker('workflow', async job => { const { fileName, runId } = job.data; try { - const result = await scheduleWorkflow(fileName, runId); + const result = await runWorkflow(fileName, runId); return result; } catch (error) { console.error('Error running workflow:', error); @@ -56,7 +56,7 @@ worker.on('failed', async (job: any, err) => { console.log('Worker and queue have been closed after failure.'); }); -async function scheduleWorkflow(fileName: string, runId: string) { +async function runWorkflow(fileName: string, runId: string) { if (!runId) { runId = uuid(); } @@ -169,4 +169,4 @@ async function executeRun(fileName: string, runId: string) { return false; } } -export { workflowQueue, scheduleWorkflow }; \ No newline at end of file +export { workflowQueue, runWorkflow }; \ No newline at end of file