From 04bcd295617bae7cb9d40d61f10e8061eddec338 Mon Sep 17 00:00:00 2001 From: Sam Doran Date: Wed, 22 Jul 2026 15:10:00 -0400 Subject: [PATCH] Fix accidental namspace package src/utils/agents was missing an __init__.py, making it a namepsace package. A side effect of this was it was being skipped by pylint. Change the namespace package to a package and address pylint failures. --- src/utils/agents/__init__.py | 1 + src/utils/agents/streaming.py | 5 ++++- src/utils/agents/tool_processor.py | 4 ++-- 3 files changed, 7 insertions(+), 3 deletions(-) create mode 100644 src/utils/agents/__init__.py diff --git a/src/utils/agents/__init__.py b/src/utils/agents/__init__.py new file mode 100644 index 000000000..b9ecc908a --- /dev/null +++ b/src/utils/agents/__init__.py @@ -0,0 +1 @@ +"""Agent helpers.""" diff --git a/src/utils/agents/streaming.py b/src/utils/agents/streaming.py index ea887d085..da6a21c54 100644 --- a/src/utils/agents/streaming.py +++ b/src/utils/agents/streaming.py @@ -1,5 +1,7 @@ """Agent streaming helpers for the streaming_query flow.""" +# pylint: disable=R0913,R0914, R0917 + from __future__ import annotations import asyncio @@ -403,7 +405,7 @@ def _process_token( @singledispatch -def dispatch_stream_event( +def dispatch_stream_event( # pylint: disable=useless-return event: AgentDispatchEvent, _state: AgentTurnAccumulator, ) -> Optional[StreamEventPayload]: @@ -417,6 +419,7 @@ def dispatch_stream_event( None when the event does not map to an SSE payload. """ logger.debug("Ignoring event kind=%s", event.event_kind) + return None diff --git a/src/utils/agents/tool_processor.py b/src/utils/agents/tool_processor.py index 77c7d516d..bb12a4e5e 100644 --- a/src/utils/agents/tool_processor.py +++ b/src/utils/agents/tool_processor.py @@ -101,7 +101,7 @@ def summarize_native_tool_call( type="mcp_call", ) case _: - logger.warning(f"Unknown tool name: {part.tool_name}") + logger.warning("Unknown tool name: %s", part.tool_name) return None @@ -184,7 +184,7 @@ def process_native_tool_result( case tool_name if tool_name.startswith(_MCP_SERVER_TOOL_PREFIX): tool_result = summarize_mcp_tool_result(part, state.tool_round) case _: - logger.warning(f"Unknown tool name: {part.tool_name}") + logger.warning("Unknown tool name: %s", part.tool_name) return None state.emitted_tool_result_ids.add(tool_result.id)