Function waitForComplete

packages/infra/test/workflow-engine-cosmos.test.ts:94–109

(
  workflow: { readonly poll: (id: string) => Effect.Effect<Option.Option<Workflow.Result<any, any>>, never, any> },
  executionId: string,
  step = Duration.millis(10),
  maxIterations = 200
)

// Helper that polls until the workflow completes (or `maxIterations` elapse).
const waitForComplete = (
  workflow: { readonly poll: (id: string) => Effect.Effect<Option.Option<Workflow.Result<any, any>>, never, any> },
  executionId: string,
  step = Duration.millis(10),
  maxIterations = 200
) =>
  Effect.gen(function*() {
    for (let i = 0; i < maxIterations; i++) {
      const polled = yield* workflow.poll(executionId)
      if (Option.isSome(polled) && polled.value._tag === "Complete") {
        return polled.value
      }
      yield* Effect.sleep(step)
    }
    return undefined
  })

const runSuite = (engineLayer: Layer.Layer<WorkflowEngine.WorkflowEngine>) => {
  const TestLayer = Handlers.pipe(