Method reportProgress

lib/job.js:164–187

(progress, cb)

  }

  reportProgress(progress, cb) {
    let promise;
    if (progress != null) {
      this.progress = progress;
      promise = this.queue._commandable().then((client) =>
        helpers.callAsync((done) =>
          client.publish(
            this.queue.toKey('events'),
            JSON.stringify({
              id: this.id,
              event: 'progress',
              data: progress,
            }),
            done
          )
        )
      );
    } else {
      promise = Promise.reject(new Error('Progress cannot be empty'));
    }

    if (cb) helpers.asCallback(promise, cb);
    return promise;
  }

  remove(cb) {
    const promise = this.queue.removeJob(this.id).then(() => this);