From 33a01f500f86a7dac80ab15546dbbb7f32671984 Mon Sep 17 00:00:00 2001 From: karishmas6 Date: Thu, 10 Oct 2024 03:21:32 +0530 Subject: [PATCH] feat: remove fileName references --- server/src/worker.ts | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/server/src/worker.ts b/server/src/worker.ts index 3afb39c5..2d4c404e 100644 --- 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 { fileName, runId } = job.data; + const { runId } = job.data; try { - const result = await handleRunRecording(fileName, runId); + const result = await handleRunRecording(runId); return result; } catch (error) { logger.error('Error running workflow:', error); @@ -31,11 +31,11 @@ const worker = new Worker('workflow', async job => { }, { connection }); worker.on('completed', async (job: any) => { - logger.log(`info`, `Job ${job.id} completed for ${job.data.fileName}_${job.data.runId}`); + logger.log(`info`, `Job ${job.id} completed for ${job.data.runId}`); }); worker.on('failed', async (job: any, err) => { - logger.log(`error`, `Job ${job.id} failed for ${job.data.fileName}_${job.data.runId}:`, err); + logger.log(`error`, `Job ${job.id} failed for ${job.data.runId}:`, err); }); console.log('Worker is running...');