diff --git a/server/src/worker.ts b/server/src/worker.ts index 1177383d..cd88a6ff 100644 --- a/server/src/worker.ts +++ b/server/src/worker.ts @@ -26,7 +26,7 @@ connection.on('error', (err) => { const workflowQueue = new Queue('workflow', { connection }); -export const worker = new Worker('workflow', async job => { +const worker = new Worker('workflow', async job => { const { fileName, runId } = job.data; try { const result = await handleRunRecording(fileName, runId); @@ -60,4 +60,4 @@ async function jobCounts() { jobCounts(); -export { workflowQueue, runWorkflow }; \ No newline at end of file +export { workflowQueue, worker }; \ No newline at end of file