Method handler

tests/test_tool_loop_agent_runner.py:382–389

(self, event, query: str = "")

        self.cancelled = False

    async def handler(self, event, query: str = ""):
        del event, query
        self.started.set()
        try:
            await asyncio.Future()
        except asyncio.CancelledError:
            self.cancelled = True
            raise


@pytest.fixture