mirror/Checkmate
1
0
Fork 0
mirror of https://github.com/bluewave-labs/Checkmate.git synced 2026-01-18 23:59:41 -06:00
Code Issues Packages Projects Releases Wiki Activity

Attempt to stop active jobs

Browse Source
This commit is contained in:
Alex Holliday
2024-10-31 16:00:29 +08:00
parent 0f30d58125
commit 120296763b
1 changed files with 26 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
Server/service/jobQueue.js
View File

@@ -36,10 +36,10 @@ class JobQueue {
host: redisHost,
port: redisPort,
};
this.connection = connection;
this.queue = new Queue(QUEUE_NAME, {
connection,
});
this.connection = connection;
this.workers = [];
this.db = null;
this.networkService = null;
@@ -406,9 +406,6 @@ class JobQueue {
delayed: await this.queue.getDelayedCount(),
repeatableJobs: (await this.queue.getRepeatableJobs()).length,
};
this.logger.info({
message: metrics,
});
return metrics;
} catch (error) {
this.logger.error({
@@ -424,17 +421,33 @@ class JobQueue {
* @async
* @returns {Promise<boolean>} - Returns true if obliteration is successful
*/
async obliterate() {
try {
let metrics = await this.getMetrics();
this.logger.info({ message: metrics });
this.logger.info({ message: "Attempting to obliterate job queue..." });
await this.queue.pause();
const jobs = await this.getJobs();
// Stop currently active jobs
const redisClient = await this.queue.client;
const activeJobs = await this.queue.getJobs(["active"]);
if (activeJobs.length !== 0) {
this.logger.info({ message: "Attempting to stop active jobs..." });
}
await Promise.all(
activeJobs.map(async (job) => {
await redisClient.del(`${this.queue.toKey(job.id)}:lock`);
await job.remove();
})
);
// Remove all repeatable jobs
for (const job of jobs) {
await this.queue.removeRepeatableByKey(job.key);
await this.queue.remove(job.id);
}
// Close workers
await Promise.all(
this.workers.map(async (worker) => {
await worker.close();
@@ -442,9 +455,13 @@ class JobQueue {
);
await this.queue.obliterate();
metrics = await this.getMetrics();
this.logger.info({ message: metrics });
this.logger.info({ message: successMessages.JOB_QUEUE_OBLITERATE });
const metrics = await this.getMetrics();
this.logger.info({
message: successMessages.JOB_QUEUE_OBLITERATE,
service: SERVICE_NAME,
method: "obliterate",
details: metrics,
});
return true;
} catch (error) {
error.service === undefined ? (error.service = SERVICE_NAME) : null;