Method stop

src/index.js:650–682

(name)

  }

  async stop(name) {
    debug('stop', name);

    if (!this._init) await this.init();

    if (name) {
      this.removeSafeTimer('timeouts', name);
      this.removeSafeTimer('intervals', name);

      if (this.workers.has(name)) {
        this.workers.get(name).once('message', (message) => {
          if (message === 'cancelled') {
            this.config.logger.info(
              `Gracefully cancelled worker for job "${name}"`,
              this.getWorkerMetadata(name)
            );
            this.workers.get(name).terminate();
          }
        });
        this.workers.get(name).postMessage('cancel');
      }

      this.removeSafeTimer('closeWorkerAfterMs', name);

      return pWaitFor(() => !this.workers.has(name));
    }

    for (const job of this.config.jobs) {
      this.stop(job.name);
    }

    return pWaitFor(() => this.workers.size === 0);
  }

  async add(jobs) {
    debug('add', jobs);