From 458ba1f6dfbe6ccae822b9f4baabc73d132b18f4 Mon Sep 17 00:00:00 2001
From: karishmas6 <carishmashukla28@gmail.com>
Date: Wed, 11 Sep 2024 13:16:45 +0530
Subject: [PATCH] feat: export worker

---
 server/src/workflow-management/scheduler/index.ts | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/server/src/workflow-management/scheduler/index.ts b/server/src/workflow-management/scheduler/index.ts
index 68a5a1ca..8714e011 100644
--- a/server/src/workflow-management/scheduler/index.ts
+++ b/server/src/workflow-management/scheduler/index.ts
@@ -11,7 +11,7 @@ const connection = new IORedis();
 
 const workflowQueue = new Queue('workflow', { connection });
 
-const worker = new Worker('workflow', async job => {
+export const worker = new Worker('workflow', async job => {
   const { fileName, runId } = job.data;
   try {
     const result = await runWorkflow(fileName, runId);
@@ -30,7 +30,7 @@ worker.on('failed', (job: any, err) => {
   console.error(`Job ${job.id} failed for ${job.data.fileName}_${job.data.runId}:`, err);
 });
 
-async function runWorkflow(fileName, runId) {
+async function runWorkflow(fileName:any, runId:any) {
   try {
     // read the recording from storage
     const recording = await readFile(`./../storage/recordings/${fileName}.waw.json`);