test: 7 attempt

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<void>((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();