diff --git a/src/claude_agent_sdk/_internal/query.py b/src/claude_agent_sdk/_internal/query.py index 8f278428..6e16918e 100644 --- a/src/claude_agent_sdk/_internal/query.py +++ b/src/claude_agent_sdk/_internal/query.py @@ -206,6 +206,10 @@ async def _read_messages(self) -> None: # TODO: Implement cancellation support continue + elif msg_type == "rate_limit_event": + # CLI handles rate limiting internally — skip informational event + continue + # Track results for proper stream closure if msg_type == "result": self._first_result_event.set() @@ -631,4 +635,4 @@ async def __anext__(self) -> dict[str, Any]: """Get next message.""" async for message in self.receive_messages(): return message - raise StopAsyncIteration + raise StopAsyncIteration \ No newline at end of file