diff --git a/tests/test_job_scheduler.ts b/tests/test_job_scheduler.ts index 45ff9ddab7..0ae67720f0 100644 --- a/tests/test_job_scheduler.ts +++ b/tests/test_job_scheduler.ts @@ -1187,18 +1187,24 @@ describe('Job Scheduler', function () { const date = new Date('2017-02-02 7:21:42'); this.clock.setSystemTime(date); - const nextTick = () => { - this.clock.tick(ONE_DAY * 31); + const nextTick = (milliseconds?: number) => { + this.clock.tick(milliseconds || ONE_DAY * 31); }; - const worker = new Worker(queueName, async () => {}, { - autorun: false, - connection, - prefix, - }); + const worker = new Worker( + queueName, + async () => { + nextTick(); + }, + { + autorun: false, + connection, + prefix, + }, + ); const delayStub = sinon.stub(worker, 'delay').callsFake(async () => {}); - let counter = 25; + let counter = 5; let prev: Job; const completing = new Promise((resolve, reject) => { worker.on('completed', async job => { @@ -1218,7 +1224,6 @@ describe('Job Scheduler', function () { if (counter == 0) { resolve(); } - nextTick(); } catch (error) { console.log(error); reject(error); @@ -1228,8 +1233,11 @@ describe('Job Scheduler', function () { worker.run(); - await queue.upsertJobScheduler('repeat', { pattern: '25 9 7 * *' }); - nextTick(); + await queue.upsertJobScheduler('repeat', { + pattern: '25 9 7 * *', + endDate: new Date('2017-06-12T14:00:00.000Z').getTime(), + }); + nextTick(ONE_DAY * 6); await completing; await worker.close();