Method runCoordinated

src/scheduler/runner.ts:114–144

* Runs `run` under the run coordinator when one is configured. If the * coordinator declines this instance, the run is skipped and `onSkipped` is * emitted with `'not-elected'`. Fail-closed: if `shouldRun` throws, the run is * skipped with `'coordinator-error'`. `onComplete` runs after the

(slot: Date, run: () => Promise<any>)

   * skipped with `'coordinator-error'`. `onComplete` runs after the task.
   */
  private async runCoordinated(slot: Date, run: () => Promise<any>): Promise<void> {
    if (!this.runCoordinator) {
      await run();
      return;
    }

    const key = `${this.coordinatorKeyPrefix}:${slot.toISOString()}`;
    let allowed: boolean;
    try {
      allowed = await this.runCoordinator.shouldRun(key, this.coordinatorTtl);
    } catch (err: any) {
      this.logger.error('Run coordinator failed; skipping execution (fail-closed)', err);
      this.emitSkipped(slot, 'coordinator-error');
      return;
    }

    if (!allowed) {
      this.emitSkipped(slot, 'not-elected');
      return;
    }

    try {
      await run();
    } finally {
      try {
        await this.runCoordinator.onComplete?.(key);
      } catch (err: any) {
        this.logger.error('Run coordinator onComplete failed', err);
      }
    }
  }

  private emitSkipped(slot: Date, reason: SkipReason){
    Promise.resolve(this.onSkipped(slot, reason)).catch((err) => this.onErrorFallback(slot, err));