Infrastructure/ghost
0
Fork 0
mirror of https://github.com/TryGhost/Ghost.git synced 2025-02-17 23:44:39 -05:00
Code Issues Activity

Updated example of scheduled on off job using date

Browse source
This commit is contained in:
Naz 2020-12-03 15:53:10 +13:00
parent eb0eb2d744
commit 30c9112bb5
2 changed files with 23 additions and 27 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
ghost/job-manager/test/examples/scheduled-one-off.js
View file

@ -1,36 +1,24 @@
/* eslint-disable no-console */
const path = require('path');
const pWaitFor = require('p-wait-for');
// const path = require('path');
const setTimeoutPromise = require('util').promisify(setTimeout);
const addSeconds = require('date-fns/addSeconds');
const JobManager = require('../../lib/job-manager');
const jobManager = new JobManager({
info: console.log,
warn: console.log,
error: console.log
});
const jobManager = new JobManager(console);
process.on('SIGINT', () => {
shutdown('SIGINT');
});
async function shutdown(signal) {
console.log(`shutting down via: ${signal}`);
await jobManager.shutdown();
}
const isJobQueueEmpty = (bree) => {
return (Object.keys(bree.workers).length === 0)
&& (Object.keys(bree.intervals).length === 0)
&& (Object.keys(bree.timeouts).length === 0);
};
(async () => {
jobManager.scheduleJob('in 10 seconds', () => {
return require('../jobs/timed-job')();
}, {
const dateInTenSeconds = addSeconds(new Date(), 10);
jobManager.scheduleJob(dateInTenSeconds, path.resolve(__dirname, '../jobs/timed-job.js'), {
ms: 2000
}, 'one-off-scheduled-job');
await setTimeoutPromise(100); // allow job to get scheduled
await pWaitFor(() => (Object.keys(jobManager.bree.workers).length === 0) && (Object.keys(jobManager.bree.intervals).length === 0));
await pWaitFor(() => (isJobQueueEmpty(jobManager.bree)));
process.exit(0);
})();

14
ghost/job-manager/test/jobs/timed-job.js
View file

@ -1,3 +1,4 @@
const {isMainThread, parentPort, workerData} = require('bthreads');
const util = require('util');
const setTimeoutPromise = util.promisify(setTimeout);
@ -7,8 +8,15 @@ const passTime = async (ms) => {
} else {
await setTimeoutPromise(ms.ms);
}
return 'done';
};
module.exports = passTime;
if (isMainThread) {
module.exports = passTime;
} else {
(async () => {
await passTime(workerData.ms);
parentPort.postMessage('done');
// alternative way to signal "finished" work (not recommended)
// process.exit();
})();
}