Method test_empty_inputs

tests/flows/test_batch.py:45–52

(self)

        self.assertEqual(result.cost_estimate_usd, 0.0)

    async def test_empty_inputs(self) -> None:
        async def flow(input: RawText, *, cfg: Any = None) -> str:
            return "x"

        result = await batch_run(flow, [], concurrency=4)
        self.assertEqual(result.total, 0)
        self.assertEqual(result.success_count, 0)
        self.assertEqual(result.results, [])

    async def test_on_error_skip_collects(self) -> None:
        async def flow(input: RawText, *, cfg: Any = None) -> str: