Method run

src/index.js:350–498

(name)

  }

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

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

    if (name) {
      const job = this.config.jobs.find((j) => j.name === name);
      if (!job) {
        throw new Error(`Job "${name}" does not exist`);
      }

      if (this.workers.has(name)) {
        this.config.logger.warn(
          new Error(`Job "${name}" is already running`),
          this.getWorkerMetadata(name)
        );
        return;
      }

      debug('starting worker', name);
      const object = {
        ...this.config.worker,
        ...job.worker,
        workerData: {
          job: {
            ...job,
            ...(job.worker ? { worker: omit(job.worker, ['env']) } : {})
          },
          ...(this.config.worker && this.config.worker.workerData
            ? this.config.worker.workerData
            : {}),
          ...(job.worker && job.worker.workerData ? job.worker.workerData : {})
        }
      };
      this.workers.set(name, this.createWorker(job.path, object));
      this.emit('worker created', name);
      debug('worker started', name);

      const prefix = `Worker for job "${name}"`;
      this.workers.get(name).on('online', () => {
        // If we specified a value for `closeWorkerAfterMs`
        // then we need to terminate it after that execution time
        const closeWorkerAfterMs = Number.isFinite(job.closeWorkerAfterMs)
          ? job.closeWorkerAfterMs
          : this.config.closeWorkerAfterMs;
        if (Number.isFinite(closeWorkerAfterMs) && closeWorkerAfterMs > 0) {
          debug('worker has close set', name, closeWorkerAfterMs);
          this.closeWorkerAfterMs.set(
            name,
            setTimeout(() => {
              /* istanbul ignore else */
              if (this.workers.has(name)) {
                debug('worker has been terminated', name);
                this.workers.get(name).terminate();
              }
            }, closeWorkerAfterMs)
          );
        }