feat: get userId from workflow queue

2024-10-10 03:24:04 +05:30
parent d2782503eb
commit 258d0aa9a2
1 changed files with 2 additions and 2 deletions
--- a/server/src/worker.ts
+++ b/server/src/worker.ts
@@ -20,9 +20,9 @@ connection.on('error', (err) => {
 const workflowQueue = new Queue('workflow', { connection });

 const worker = new Worker('workflow', async job => {
-    const { runId } = job.data;
+    const { runId, userId  } = job.data;
    try {
-        const result = await handleRunRecording(runId);
+        const result = await handleRunRecording(runId, userId);
        return result;
    } catch (error) {
        logger.error('Error running workflow:', error);