perf(worker): fetch next job on failure

src/classes/job.ts

@@ -32,7 +32,7 @@ import {
   tryCatch,
 } from '../utils';
 import { Backoffs } from './backoffs';
-import { Scripts } from './scripts';
+import { Scripts, raw2NextJobData } from './scripts';
 import { UnrecoverableError } from './errors/unrecoverable-error';
 import type { QueueEvents } from './queue-events';
 
@@ -616,7 +616,7 @@ export class Job<
     err: E,
     token: string,
     fetchNext = false,
-  ): Promise<void> {
+  ): Promise<void | any[]> {
     const client = await this.queue.client;
     const message = err?.message;
 
@@ -693,9 +693,9 @@ export class Job<
       );
     }
 
-    const code = results[results.length - 1][1] as number;
-    if (code < 0) {
-      throw this.scripts.finishedErrors(code, this.id, command, 'active');
+    const result = results[results.length - 1][1] as number;
+    if (result < 0) {
+      throw this.scripts.finishedErrors(result, this.id, command, 'active');
     }
 
     if (finishedOn && typeof finishedOn === 'number') {
@@ -707,6 +707,10 @@ export class Job<
     }
 
     this.attemptsMade += 1;
+
+    if (Array.isArray(result)) {
+      return raw2NextJobData(result);
+    }
   }
 
   /**

src/classes/worker.ts

@@ -715,8 +715,14 @@ export class Worker<
             return;
           }
 
-          await job.moveToFailed(err, token);
+          const failed = await job.moveToFailed(err, token, true);
           this.emit('failed', job, err, 'active');
+
+          if (failed) {
+            const [jobData, jobId, limitUntil, delayUntil] = failed || [];
+            this.updateDelays(limitUntil, delayUntil);
+            return this.nextJobFromJobData(jobData, jobId, token);
+          }
         } catch (err) {
           this.emit('error', <Error>err);
           // It probably means that the job has lost the lock before completion
@@ -735,7 +741,7 @@ export class Worker<
       const result = await this.callProcessJob(job, token);
       return await handleCompleted(result);
     } catch (err) {
-      return handleFailed(<Error>err);
+      return await handleFailed(<Error>err);
     } finally {
       jobsInProgress.delete(inProgressItem);
     }