Function heartbeat

packages/infra/src/WorkflowEngineSqlite.ts:477–498

(executionId: string)

    })

  const heartbeat = (executionId: string): Effect.Effect<void> =>
    Effect.gen(function*() {
      while (true) {
        yield* Effect.sleep(heartbeatInterval)
        const local = locals.get(executionId)
        const polled = local?.fiber?.pollUnsafe()
        if (!local?.fiber || polled) return
        const cur = yield* readExec(executionId).pipe(
          Effect.catchCause(() => Effect.succeed(Option.none<ExecState>()))
        )
        if (Option.isNone(cur)) continue
        const state = cur.value
        if (state.status === "complete" || state.worker !== workerId) return
        yield* replaceExec(state, {
          leaseExpiresAt: Date.now() + Duration.toMillis(leaseTtl)
        })
          .pipe(
            Effect.catchTag("OptimisticConcurrencyException", () => Effect.void),
            Effect.catchCause(() => Effect.void)
          )
      }
    })

  // --- Drive logic ------------------------------------------------------