Method shouldRun

src/coordinator/ipc-run-coordinator.ts:37–48

(key: string, ttlMs: number)

  }

  shouldRun(key: string, ttlMs: number): Promise<boolean> {
    const reqId = createID();
    return new Promise<boolean>((resolve, reject) => {
      this.pending.set(reqId, (result) => {
        // The parent reports a coordinator error by replying with `error`; reject
        // so the runner fails closed (skips the run), mirroring the inline path.
        if (result.error) reject(new Error(result.error));
        else resolve(result.allowed);
      });
      this.channel.send?.({ type: 'coordinator:shouldRun', key, ttlMs, reqId });
    });
  }

  onComplete(key: string): Promise<void> {
    this.channel.send?.({ type: 'coordinator:complete', key });