mirror/Checkmate
1
0
Fork 0
mirror of https://github.com/bluewave-labs/Checkmate.git synced 2026-01-19 08:09:45 -06:00
Code Issues Packages Projects Releases Wiki Activity

made adding jobs and scaling workers non-blocking

Browse Source
This commit is contained in:
Alex Holliday
2024-12-27 14:00:47 -08:00
parent 955d3c6298
commit d686a8de5e
1 changed files with 22 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
Server/service/jobQueue.js
View File

@@ -90,11 +90,30 @@ class JobQueue {
const monitors = await db.getAllMonitors();
for (const monitor of monitors) {
if (monitor.isActive) {
await queue.addJob(monitor.id, monitor);
queue.addJob(monitor.id, monitor).catch((error) => {
this.logger.error({
message: error.message,
service: SERVICE_NAME,
method: "createJobQueue",
stack: error.stack,
});
});
}
}
const workerStats = await queue.getWorkerStats();
await queue.scaleWorkers(workerStats);
queue
.getWorkerStats()
.then((workerStats) => {
queue.scaleWorkers(workerStats);
})
.catch((error) => {
this.logger.error({
message: error.message,
service: SERVICE_NAME,
method: "createJobQueue",
stack: error.stack,
});
});
return queue;
} catch (error) {
error.service === undefined ? (error.service = SERVICE_NAME) : null;