Method heartBeat

src/scheduler/runner.ts:212–255

()

    }

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

      const plan = planBeat(
        expectedNextExecution,
        currentDate,
        this.missedExecutionTolerance,
        (date: Date) => this.timeMatcher.getNextMatch(date)
      );

      expectedNextExecution = plan.next;

      // Report every superseded slot. The "missed execution" warning is emitted
      // by the task's onMissedExecution handler so it can honour listener-based
      // and explicit suppression and use the task's logger.
      for (const missedSlot of plan.missed) {
        runAsync(this.onMissedExecution, missedSlot, this.onErrorFallback);
      }

      if (plan.run) {
        // overlap prevention
        if (lastExecution && lastExecution.getState() === 'pending') {
          runAsync(this.onOverlap, plan.run, this.onErrorFallback);
          if (this.noOverlap) {
            this.logger.warn('task still running, new execution blocked by overlap prevention!');
            armHeartBeat();
            return;
          }
        }

        const slot = plan.run;
        lastExecution = new TrackedPromise(async (resolve, reject) => {
          try {
            await this.runCoordinated(slot, () => runTask(slot));
            resolve(true);
          } catch (err) {
            reject(err);
          }
        });
      }

      armHeartBeat();
    }

    armHeartBeat();
  }