Function markInterrupted

packages/infra/src/WorkflowEngineCosmos.ts:477–490

(executionId: string)

  // synchronous writes never interleave here — Cosmos round-trips open a real
  // race window, so the write must converge rather than swallow the conflict.
  const markInterrupted = (executionId: string): Effect.Effect<void> =>
    Effect.gen(function*() {
      while (true) {
        const current = yield* readExec(executionId)
        if (Option.isNone(current) || current.value.status === "complete" || current.value.interrupted) {
          return
        }
        const persisted = yield* replaceExec({ ...current.value, interrupted: true }).pipe(
          Effect.as(true),
          Effect.catchTag("OptimisticConcurrencyException", () => Effect.succeed(false))
        )
        if (persisted) return
      }
    })

  // --- Encoded engine ----------------------------------------------------