(input: RawText, *, cfg: Any = None)
| 29 | class BatchRunTests(unittest.IsolatedAsyncioTestCase): |
| 30 | async def test_happy_path(self) -> None: |
| 31 | async def flow(input: RawText, *, cfg: Any = None) -> str: |
| 32 | return f"ok:{input.text}" |
| 33 | |
| 34 | inputs = [RawText(text=str(i)) for i in range(5)] |
| 35 | result = await batch_run(flow, inputs, concurrency=3) |
nothing calls this directly
no outgoing calls
no test coverage detected