(self)
| 82 | self.assertIs(ctx.exception, boom) |
| 83 | |
| 84 | async def test_memory_kwarg_rejected(self) -> None: |
| 85 | async def flow(input: RawText, *, cfg: Any = None) -> str: |
| 86 | return "x" |
| 87 | |
| 88 | with self.assertRaises(ValueError) as ctx: |
| 89 | await batch_run(flow, [RawText(text="x")], memory=object()) |
| 90 | self.assertIn("memory", str(ctx.exception)) |
| 91 | |
| 92 | async def test_concurrency_must_be_at_least_one(self) -> None: |
| 93 | async def flow(input: RawText, *, cfg: Any = None) -> str: |