(self)
| 148 | self.assertIs(seen_cfg[0], cfg) |
| 149 | |
| 150 | async def test_extra_kwargs_forwarded(self) -> None: |
| 151 | seen: list[Any] = [] |
| 152 | |
| 153 | async def flow( |
| 154 | input: RawText, *, cfg: Any = None, marker: str = "" |
| 155 | ) -> str: |
| 156 | seen.append(marker) |
| 157 | return "ok" |
| 158 | |
| 159 | await batch_run(flow, [RawText(text="x")], concurrency=1, marker="here") |
| 160 | self.assertEqual(seen, ["here"]) |