Function waitForStep

packages/infra/test/cluster-sqlite.test.ts:194–201

(log: StepLog["Service"], step: string)

    }
    return yield* Effect.fail(new Error(`Workflow ${executionId} did not complete`))
  })

const waitForStep = (log: StepLog["Service"], step: string) =>
  Effect.gen(function*() {
    for (let i = 0; i < 100; i++) {
      if (log.steps.includes(step)) return
      yield* Effect.sleep(Duration.millis(100))
    }
    return yield* Effect.fail(new Error(`Workflow did not reach ${step}`))
  })