perf(worker): fetch next job on failure

src/classes/job.ts

@@ -31,7 +31,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';
 
@@ -602,7 +602,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;
 
@@ -679,9 +679,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') {
@@ -691,6 +691,10 @@ export class Job<
     if (delay && typeof delay === 'number') {
       this.delay = delay;
     }
+
+    if (Array.isArray(result)) {
+      return raw2NextJobData(result);
+    }
   }
 
   /**

src/classes/worker.ts

@@ -711,8 +711,13 @@ export class Worker<
             return;
           }
 
-          await job.moveToFailed(err, token);
+          const failed = await job.moveToFailed(err, token, true);
           this.emit('failed', job, err, 'active');
+
+          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
@@ -731,7 +736,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);
     }