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

feat: logging

Browse Source
This commit is contained in:
karishmas6
2024-09-12 21:08:36 +05:30
parent 0b8b735289
commit 5482de258d
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
server/src/workflow-management/scheduler/index.ts
View File

@@ -33,25 +33,25 @@ export const worker = new Worker('workflow', async job => {
const result = await handleRunRecording(fileName, runId); const result = await handleRunRecording(fileName, runId);
return result; return result;
} catch (error) { } catch (error) {
console.error('Error running workflow:', error); logger.error('Error running workflow:', error);
throw error; throw error;
} }
}, { connection }); }, { connection });
worker.on('completed', async (job: any) => { worker.on('completed', async (job: any) => {
console.log(`Job ${job.id} completed for ${job.data.fileName}_${job.data.runId}`); logger.log(`info`,`Job ${job.id} completed for ${job.data.fileName}_${job.data.runId}`);
await worker.close(); await worker.close();
await workflowQueue.close(); await workflowQueue.close();
console.log('Worker and queue have been closed.'); logger.log(`info`,`Worker and queue have been closed.`);
}); });
worker.on('failed', async (job: any, err) => { worker.on('failed', async (job: any, err) => {
console.error(`Job ${job.id} failed for ${job.data.fileName}_${job.data.runId}:`, err); logger.log(`error`, `Job ${job.id} failed for ${job.data.fileName}_${job.data.runId}:`, err);
await worker.close(); await worker.close();
await workflowQueue.close(); await workflowQueue.close();
console.log('Worker and queue have been closed after failure.'); logger.log(`info`, `Worker and queue have been closed after failure.`);
}); });
const existingJobs = workflowQueue.getRepeatableJobs(); const existingJobs = workflowQueue.getRepeatableJobs();
@@ -184,7 +184,7 @@ async function readyForRunHandler(browserId: string, fileName: string, runId: st
resetRecordingState(browserId, fileName, runId); resetRecordingState(browserId, fileName, runId);
} catch (error: any) { } catch (error: any) {
console.error(`Error during readyForRunHandler: ${error.message}`); logger.error(`Error during readyForRunHandler: ${error.message}`);
await destroyRemoteBrowser(browserId); await destroyRemoteBrowser(browserId);
} }
} }
@@ -219,7 +219,7 @@ async function handleRunRecording(fileName: string, runId: string) {
}); });
} catch (error: any) { } catch (error: any) {
console.error('Error running recording:', error); logger.error('Error running recording:', error);
} }
} }