Function tryClaim

packages/infra/src/WorkflowEngineSqlite.ts:463–475

(state: ExecState)

    && state.leaseExpiresAt > now

  const tryClaim = (state: ExecState): Effect.Effect<Option.Option<ExecState>> =>
    Effect.gen(function*() {
      const now = Date.now()
      if (leaseActive(state, now)) return Option.none<ExecState>()
      return yield* replaceExec(state, {
        worker: workerId,
        leaseExpiresAt: now + Duration.toMillis(leaseTtl)
      })
        .pipe(
          Effect.map(Option.some),
          Effect.catchTag("OptimisticConcurrencyException", () => Effect.succeed(Option.none<ExecState>()))
        )
    })

  const heartbeat = (executionId: string): Effect.Effect<void> =>
    Effect.gen(function*() {