(
self, *, ctx: Context, node_input: Any
)
| 958 | rerun_on_resume: bool = True |
| 959 | |
| 960 | async def _run_impl( |
| 961 | self, *, ctx: Context, node_input: Any |
| 962 | ) -> AsyncGenerator[Any, None]: |
| 963 | a = await ctx.run_node(_CountingChild(name='a'), 'x') |
| 964 | b = await ctx.run_node(_CountingChild(name='b'), 'y') |
| 965 | c = await ctx.run_node(_CountingChild(name='c'), 'z') |
| 966 | yield f'{a},{b},{c}' |
| 967 | |
| 968 | events1, events2, _, _, _ = await _run_two_turns( |
| 969 | _Parent(name='p'), |
nothing calls this directly
no test coverage detected