mirror of
https://github.com/TryGhost/Ghost.git
synced 2025-01-06 22:40:14 -05:00
Improved job queue logging
no issue - Makes debugging scheduled jobs easier by listing running/scheduled job names
This commit is contained in:
parent
dec93a4b72
commit
0e78f2ed63
1 changed files with 14 additions and 1 deletions
|
@ -126,7 +126,20 @@ class GhostServer {
|
||||||
// Output job queue length every 5 seconds
|
// Output job queue length every 5 seconds
|
||||||
setInterval(() => {
|
setInterval(() => {
|
||||||
logging.warn(`${jobService.queue.length()} jobs in the queue. Idle: ${jobService.queue.idle()}`);
|
logging.warn(`${jobService.queue.length()} jobs in the queue. Idle: ${jobService.queue.idle()}`);
|
||||||
logging.warn(`${Object.keys(jobService.bree.workers).length} workers registered. Scheduled jobs: ${Object.keys(jobService.bree.intervals).length}`);
|
|
||||||
|
const runningScheduledjobs = Object.keys(jobService.bree.workers);
|
||||||
|
if (Object.keys(jobService.bree.workers).length) {
|
||||||
|
logging.warn(`${Object.keys(jobService.bree.workers).length} jobs running: ${runningScheduledjobs}`);
|
||||||
|
}
|
||||||
|
|
||||||
|
const scheduledJobs = Object.keys(jobService.bree.intervals);
|
||||||
|
if (Object.keys(jobService.bree.intervals).length) {
|
||||||
|
logging.warn(`${Object.keys(jobService.bree.intervals).length} scheduled jobs: ${scheduledJobs}`);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (runningScheduledjobs.length === 0 && scheduledJobs.length === 0) {
|
||||||
|
logging.warn('No scheduled or running jobs');
|
||||||
|
}
|
||||||
}, 5000);
|
}, 5000);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue