Method renewLease

src/node/services/workflows/WorkflowRunStore.ts:736–760

(runId: string, ownerId: string, nowMs = Date.now())

  }

  async renewLease(runId: string, ownerId: string, nowMs = Date.now()): Promise<boolean> {
    assert(ownerId.length > 0, "WorkflowRunStore.renewLease: ownerId is required");
    const leaseFile = this.leaseFile(runId);
    const lockDir = `${leaseFile}.lock`;
    try {
      await acquireWorkflowMutationLock(
        lockDir,
        this.leaseMutationLockStaleMs(),
        this.leaseMutationWaitTimeoutMs()
      );
    } catch {
      return false;
    }

    try {
      const existing = await readLease(leaseFile);
      if (existing?.ownerId !== ownerId) {
        return false;
      }
      await writeJsonAtomic(leaseFile, { ownerId, acquiredAtMs: nowMs } satisfies LeaseRecord);
      return true;
    } finally {
      await fs.rm(lockDir, { recursive: true, force: true });
    }
  }

  async releaseLease(runId: string, ownerId: string): Promise<void> {
    const leaseFile = this.leaseFile(runId);