Function acquireWorkflowMutationLock

src/node/services/workflows/WorkflowRunStore.ts:1213–1229

(
  lockDir: string,
  staleLeaseMs: number,
  timeoutMs = staleLeaseMs
)

}

async function acquireWorkflowMutationLock(
  lockDir: string,
  staleLeaseMs: number,
  timeoutMs = staleLeaseMs
): Promise<void> {
  const deadline = Date.now() + timeoutMs;
  while (Date.now() <= deadline) {
    if (await acquireLeaseMutationLock(lockDir, Date.now(), staleLeaseMs)) {
      return;
    }
    // Jittered backoff: a fixed sleep can phase-lock with the periodic lease renewal (whose
    // interval is also a small constant when staleLeaseMs is short, e.g. in tests), so every
    // retry lands while a renewal holds the lock and waiters starve for hundreds of ms.
    await new Promise((resolve) => setTimeout(resolve, 2 + Math.random() * 6));
  }
  throw new Error(`Timed out acquiring workflow mutation lock: ${lockDir}`);
}

async function acquireLeaseMutationLock(
  lockDir: string,