(ctx: InvocationContext)
| 1101 | return |
| 1102 | |
| 1103 | async def execute(ctx: InvocationContext) -> AsyncGenerator[Event]: |
| 1104 | async with aclosing(ctx.agent.run_async(ctx)) as agen: |
| 1105 | async for event in agen: |
| 1106 | yield event |
| 1107 | |
| 1108 | async with aclosing( |
| 1109 | self._exec_with_plugin( |
no test coverage detected