feat(job): add moveToWait method for manual processing

src/classes/job.ts

@@ -692,6 +692,16 @@ export class Job<
     return result;
   }
 
+  /**
+   * Moves a job to the wait or prioritized state.
+   *
+   * @param token - Worker token used to acquire completed job.
+   * @returns Returns pttl.
+   */
+  moveToWait(token: string): Promise<number> {
+    return this.scripts.moveJobFromActiveToWait(this.id, token);
+  }
+
   private async shouldRetryJob(err: Error): Promise<[boolean, number]> {
     if (
       this.attemptsMade + 1 < this.opts.attempts &&

src/classes/worker.ts

@@ -1285,6 +1285,6 @@ will never work with more accuracy than 1ms. */
     job: Job<DataType, ResultType, NameType>,
     token: string,
   ) {
-    return this.scripts.moveJobFromActiveToWait(job.id, token);
+    return job.moveToWait(token);
   }
 }

tests/test_job.ts

@@ -933,6 +933,21 @@ describe('Job', function () {
     });
   });
 
+  describe('.moveToWait', () => {
+    it('moves job to wait from active', async function () {
+      const worker = new Worker(queueName, null, { connection, prefix });
+      const token = 'my-token';
+      await Job.create(queue, 'test', { foo: 'bar' });
+      const job = (await worker.getNextJob(token)) as Job;
+      const isWaiting = await job.isWaiting();
+      expect(isWaiting).to.be.equal(false);
+      await job.moveToWait(token);
+      const isisWaiting2 = await job.isWaiting();
+      expect(isisWaiting2).to.be.equal(true);
+      await worker.close();
+    });
+  });
+
   describe('.changeDelay', () => {
     it('can change delay of a delayed job', async function () {
       this.timeout(8000);