Method runTask

src/scheduler/runner.ts:163–210

(date: Date)

    };

    const runTask = (date: Date): Promise<any> => {
      return new Promise(async (resolve) => {
        const execution: Execution = {
          id: createID(),
          reason: 'scheduled'
        }

        const shouldExecute = await this.beforeRun(date, execution);
        const randomDelay = Math.floor(Math.random() * this.maxRandomDelay);

        if(shouldExecute){
          const execute = async () => {
            try {
              this.runCount++;
              execution.startedAt = new Date();
              const result = await this.onMatch(date, execution);
              execution.finishedAt = new Date();
              execution.result = result;
              this.onFinished(date, execution);

              if( this.maxExecutions && this.runCount >= this.maxExecutions){
                this.onMaxExecutions(date);
                this.stop();
              }
            } catch (error: any){
              execution.finishedAt = new Date();
              execution.error = error;
              this.onError(date, error, execution);
            }

            resolve(true);
          };

          // The jitter timer only earns its macrotask hop when a random delay is
          // actually configured. With the default maxRandomDelay of 0 the delay
          // is always 0, so run inline and fire on the heartbeat's own tick
          // instead of bouncing through an extra setTimeout (which adds ~1ms+ of
          // avoidable drift to every execution).
          if (randomDelay > 0) {
            setTimeout(execute, randomDelay);
          } else {
            execute();
          }
        } else {
          resolve(true);
        }
      })
    }

    const heartBeat = async () => {
      // ignore milliseconds so the comparison against the matched slot is exact.