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)