vodorod/parcer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: remove fileName references

Browse Source
This commit is contained in:
karishmas6
2024-10-10 03:21:32 +05:30
parent 4d7679d5a9
commit 33a01f500f
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
server/src/worker.ts
View File

@@ -20,9 +20,9 @@ connection.on('error', (err) => {
const workflowQueue = new Queue('workflow', { connection }); const workflowQueue = new Queue('workflow', { connection });
const worker = new Worker('workflow', async job => { const worker = new Worker('workflow', async job => {
const { fileName, runId } = job.data; const { runId } = job.data;
try { try {
const result = await handleRunRecording(fileName, runId); const result = await handleRunRecording(runId);
return result; return result;
} catch (error) { } catch (error) {
logger.error('Error running workflow:', error); logger.error('Error running workflow:', error);
@@ -31,11 +31,11 @@ const worker = new Worker('workflow', async job => {
}, { connection }); }, { connection });
worker.on('completed', async (job: any) => { 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) => { 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...'); console.log('Worker is running...');