refactor(scripts): add protected moveStalledJobsToWaitArgs method (#2538

)

src/classes/scripts.ts

@@ -1092,18 +1092,7 @@ export class Scripts {
     }
   }
 
-  /**
-   * Looks for unlocked jobs in the active queue.
-   *
-   * The job was being worked on, but the worker process died and it failed to renew the lock.
-   * We call these jobs 'stalled'. This is the most common case. We resolve these by moving them
-   * back to wait to be re-processed. To prevent jobs from cycling endlessly between active and wait,
-   * (e.g. if the job handler keeps crashing),
-   * we limit the number stalled job recoveries to settings.maxStalledCount.
-   */
-  async moveStalledJobsToWait(): Promise<[string[], string[]]> {
-    const client = await this.queue.client;
-
+  protected moveStalledJobsToWaitArgs(): (string | number)[] {
     const opts = this.queue.opts as WorkerOptions;
     const keys: (string | number)[] = [
       this.queue.keys.stalled,
@@ -1122,7 +1111,25 @@ export class Scripts {
       Date.now(),
       opts.stalledInterval,
     ];
-    return (<any>client).moveStalledJobsToWait(keys.concat(args));
+
+    return keys.concat(args);
+  }
+
+  /**
+   * Looks for unlocked jobs in the active queue.
+   *
+   * The job was being worked on, but the worker process died and it failed to renew the lock.
+   * We call these jobs 'stalled'. This is the most common case. We resolve these by moving them
+   * back to wait to be re-processed. To prevent jobs from cycling endlessly between active and wait,
+   * (e.g. if the job handler keeps crashing),
+   * we limit the number stalled job recoveries to settings.maxStalledCount.
+   */
+  async moveStalledJobsToWait(): Promise<[string[], string[]]> {
+    const client = await this.queue.client;
+
+    const args = this.moveStalledJobsToWaitArgs();
+
+    return (<any>client).moveStalledJobsToWait(args);
   }
 
   /**