Method delByFunction

src/core/queue.ts:230–262

* delByFunction * * will delete all jobs in the given queue of the named function/class * * will not prevent new jobs from being added as this method is running * * will not delete jobs in the delayed queues * @param q - queue to look in * @param func - function name to delete any

(
    q: string,
    func: string,
    start: number = 0,
    stop: number = -1,
  )

   * @returns number of jobs deleted from queue
   */
  async delByFunction(
    q: string,
    func: string,
    start: number = 0,
    stop: number = -1,
  ) {
    const jobs = await this.connection.redis.lrange(
      this.connection.key("queue", q),
      start,
      stop,
    );
    let numJobsDeleted: number = 0;
    const pipeline = this.connection.redis.multi();

    for (let i = 0; i < jobs.length; i++) {
      const jobEncoded = jobs[i];
      const { class: jobFunc } = JSON.parse(jobEncoded) as ParsedJob;
      if (jobFunc === func) {
        pipeline.lrem(this.connection.key("queue", q), 0, jobEncoded);
        numJobsDeleted++;
      }
    }

    const response = await pipeline.exec();

    response?.forEach((res) => {
      if (res[0] !== null) {
        throw res[0];
      }
    });

    return numJobsDeleted;
  }

  async delDelayed(q: string, func: string, args: Array<any> = []) {
    const timestamps = [];