Function tryClaim

packages/infra/src/WorkflowEngineCosmos.ts:321–334

(state: ExecDoc)

   * retry by re-reading).
   */
  const tryClaim = (state: ExecDoc): Effect.Effect<Option.Option<ExecDoc>> =>
    Effect.gen(function*() {
      const now = Date.now()
      if (leaseActive(state, now)) return Option.none<ExecDoc>()
      const updated: ExecDoc = {
        ...state,
        worker: workerId,
        leaseExpiresAt: new Date(now + Duration.toMillis(leaseTtl)).toISOString()
      }
      return yield* replaceExec(updated).pipe(
        Effect.map(Option.some),
        Effect.catchTag("OptimisticConcurrencyException", () => Effect.succeed(Option.none<ExecDoc>()))
      )
    })

  /**
   * Renew lease until the local fiber stops or another worker takes the claim.