Method recordRunFinish

src/schedule/store.ts:183–212

* Record the result of a run and atomically advance next_run_at. * * Returns true if this caller won the claim, false if a concurrent tick had * already advanced next_run_at. The whole thing is one transaction: we * advance next_run_at FIRST (the atomic claim), and only if we win do we

(runId: number, scheduleId: string, status: 'success' | 'error' | 'skipped', exitCode: number, message: string, durationMs: number)

   * "this run did not happen / do not fire".
   */
  recordRunFinish(runId: number, scheduleId: string, status: 'success' | 'error' | 'skipped', exitCode: number, message: string, durationMs: number): boolean {
    const CLAIM_LOST = Symbol('claim-lost');
    const tx = this.db.transaction(() => {
      // Atomic claim first: if we lose the race, abort the transaction so none
      // of the bookkeeping below is committed.
      if (!this.recomputeNext(scheduleId)) {
        throw CLAIM_LOST;
      }
      this.db.prepare(`
        UPDATE schedule_runs SET finished_at = CURRENT_TIMESTAMP, status = ?, exit_code = ?, message = ?, duration_ms = ?
        WHERE id = ?
      `).run(status, exitCode, message, durationMs, runId);
      this.db.prepare(`
        UPDATE schedules SET
          last_run_at = CURRENT_TIMESTAMP,
          last_status = ?,
          last_message = ?,
          last_duration_ms = ?,
          run_count = run_count + 1
        WHERE id = ?
      `).run(status, message, durationMs, scheduleId);
    });
    try {
      tx();
      return true;
    } catch (err) {
      if (err === CLAIM_LOST) return false;
      throw err;
    }
  }

  /**
   * Recompute next_run_at from now. Called after every run and on enable.