Function heartbeat

packages/infra/src/WorkflowEngineCosmos.ts:340–362

(executionId: string)

   * Best-effort: failures are swallowed; loop simply retries on next tick.
   */
  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<ExecDoc>()))
        )
        if (Option.isNone(cur)) continue
        const state = cur.value
        if (state.status === "complete" || state.worker !== workerId) return
        yield* replaceExec({
          ...state,
          leaseExpiresAt: new Date(Date.now() + Duration.toMillis(leaseTtl)).toISOString()
        })
          .pipe(
            Effect.catchTag("OptimisticConcurrencyException", () => Effect.void),
            Effect.catchCause(() => Effect.void)
          )
      }
    })

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