Function leaseActive

packages/infra/src/WorkflowEngineSqlite.ts:457–461

(state: ExecState, now: number)

  // --- Lease / claim ----------------------------------------------------

  const leaseActive = (state: ExecState, now: number): boolean =>
    state.worker !== undefined
    && state.worker !== workerId
    && state.leaseExpiresAt !== undefined
    && state.leaseExpiresAt > now

  const tryClaim = (state: ExecState): Effect.Effect<Option.Option<ExecState>> =>
    Effect.gen(function*() {