fix linting

Author: prassanna-ravishankar

examples/tutorials/10_async/10_temporal/090_claude_agents_sdk_mvp/project/run_worker.py

@@ -9,22 +9,23 @@
 - Standard AgentEx activities (messages, streaming, tracing)
 """
 
-import asyncio
 import os
-from agentex.lib.core.temporal.workers.worker import AgentexWorker
-from agentex.lib.core.temporal.activities import get_all_activities
-from agentex.lib.environment_variables import EnvironmentVariables
+import asyncio
+
+# Import workflow and workspace activity
+from project.workflow import ClaudeMvpWorkflow, create_workspace_directory
+
 from agentex.lib.utils.logging import make_logger
+from agentex.lib.environment_variables import EnvironmentVariables
+from agentex.lib.core.temporal.activities import get_all_activities
+from agentex.lib.core.temporal.workers.worker import AgentexWorker
 
 # Import Claude components
 from agentex.lib.core.temporal.plugins.claude_agents import (
-    run_claude_agent_activity,
     ContextInterceptor,  # Reuse from OpenAI!
+    run_claude_agent_activity,
 )
 
-# Import workflow and workspace activity
-from project.workflow import ClaudeMvpWorkflow, create_workspace_directory
-
 logger = make_logger(__name__)
 
 

examples/tutorials/10_async/10_temporal/090_claude_agents_sdk_mvp/project/workflow.py

@@ -16,23 +16,24 @@
 - Subagents
 - Tracing
 """
+from __future__ import annotations
 
-from claude_agent_sdk.types import AgentDefinition
 import os
 from pathlib import Path
-from temporalio import workflow
-from temporalio import activity
-from temporalio.common import RetryPolicy
 from datetime import timedelta
 
+from temporalio import activity, workflow
+from temporalio.common import RetryPolicy
+from claude_agent_sdk.types import AgentDefinition
+
 from agentex.lib import adk
 from agentex.lib.types.acp import SendEventParams, CreateTaskParams
-from agentex.lib.core.temporal.types.workflow import SignalName
-from agentex.lib.core.temporal.workflows.workflow import BaseWorkflow
-from agentex.lib.environment_variables import EnvironmentVariables
-from agentex.types.text_content import TextContent
 from agentex.lib.utils.logging import make_logger
+from agentex.types.text_content import TextContent
 from agentex.lib.utils.model_utils import BaseModel
+from agentex.lib.environment_variables import EnvironmentVariables
+from agentex.lib.core.temporal.types.workflow import SignalName
+from agentex.lib.core.temporal.workflows.workflow import BaseWorkflow
 
 # Import Claude activity
 from agentex.lib.core.temporal.plugins.claude_agents import run_claude_agent_activity

src/agentex/lib/core/temporal/plugins/claude_agents/__init__.py

@@ -35,20 +35,18 @@
     await worker.run(activities=activities, workflow=YourWorkflow)
 """
 
+from agentex.lib.core.temporal.plugins.claude_agents.hooks import (
+    TemporalStreamingHooks,
+    create_streaming_hooks,
+)
 from agentex.lib.core.temporal.plugins.claude_agents.activities import (
     run_claude_agent_activity,
     create_workspace_directory,
 )
-
 from agentex.lib.core.temporal.plugins.claude_agents.message_handler import (
     ClaudeMessageHandler,
 )
 
-from agentex.lib.core.temporal.plugins.claude_agents.hooks import (
-    create_streaming_hooks,
-    TemporalStreamingHooks,
-)
-
 # Reuse OpenAI's context threading - this is the key to streaming!
 from agentex.lib.core.temporal.plugins.openai_agents.interceptors.context_interceptor import (
     ContextInterceptor,

src/agentex/lib/core/temporal/plugins/claude_agents/activities.py

@@ -3,20 +3,20 @@
 from __future__ import annotations
 
 import os
-from pathlib import Path
 from typing import Any
+from pathlib import Path
 
 from temporalio import activity
-from claude_agent_sdk import ClaudeSDKClient, ClaudeAgentOptions, AgentDefinition
+from claude_agent_sdk import AgentDefinition, ClaudeSDKClient, ClaudeAgentOptions
 
 from agentex.lib.utils.logging import make_logger
+from agentex.lib.core.temporal.plugins.claude_agents.hooks import create_streaming_hooks
+from agentex.lib.core.temporal.plugins.claude_agents.message_handler import ClaudeMessageHandler
 from agentex.lib.core.temporal.plugins.openai_agents.interceptors.context_interceptor import (
     streaming_task_id,
     streaming_trace_id,
     streaming_parent_span_id,
 )
-from agentex.lib.core.temporal.plugins.claude_agents.message_handler import ClaudeMessageHandler
-from agentex.lib.core.temporal.plugins.claude_agents.hooks import create_streaming_hooks
 
 logger = make_logger(__name__)
 

src/agentex/lib/core/temporal/plugins/claude_agents/hooks/__init__.py

@@ -1,8 +1,8 @@
 """Claude SDK hooks for streaming lifecycle events to AgentEx UI."""
 
 from agentex.lib.core.temporal.plugins.claude_agents.hooks.hooks import (
-    create_streaming_hooks,
     TemporalStreamingHooks,
+    create_streaming_hooks,
 )
 
 __all__ = [

src/agentex/lib/core/temporal/plugins/claude_agents/hooks/hooks.py

@@ -10,11 +10,11 @@
 
 from claude_agent_sdk import HookMatcher
 
-from agentex.lib.utils.logging import make_logger
 from agentex.lib import adk
+from agentex.lib.utils.logging import make_logger
+from agentex.types.task_message_update import StreamTaskMessageFull
 from agentex.types.tool_request_content import ToolRequestContent
 from agentex.types.tool_response_content import ToolResponseContent
-from agentex.types.task_message_update import StreamTaskMessageFull
 
 logger = make_logger(__name__)
 
@@ -53,7 +53,7 @@ async def pre_tool_use(
         self,
         input_data: dict[str, Any],
         tool_use_id: str | None,
-        context: Any,
+        _context: Any,
     ) -> dict[str, Any]:
         """Hook called before tool execution.
 
@@ -120,7 +120,7 @@ async def post_tool_use(
         self,
         input_data: dict[str, Any],
         tool_use_id: str | None,
-        context: Any,
+        _context: Any,
     ) -> dict[str, Any]:
         """Hook called after tool execution.
 

src/agentex/lib/core/temporal/plugins/claude_agents/message_handler.py

@@ -13,14 +13,14 @@
 from typing import Any
 
 from claude_agent_sdk import (
-    AssistantMessage,
     TextBlock,
-    SystemMessage,
     ResultMessage,
+    SystemMessage,
+    AssistantMessage,
 )
 
-from agentex.lib.utils.logging import make_logger
 from agentex.lib import adk
+from agentex.lib.utils.logging import make_logger
 from agentex.types.text_content import TextContent
 from agentex.types.task_message_delta import TextDelta
 from agentex.types.task_message_update import StreamTaskMessageDelta
@@ -96,7 +96,7 @@ async def handle_message(self, message: Any):
         elif isinstance(message, ResultMessage):
             await self._handle_result_message(message)
 
-    async def _handle_assistant_message(self, message: AssistantMessage, msg_num: int):
+    async def _handle_assistant_message(self, message: AssistantMessage, _msg_num: int):
         """Handle AssistantMessage - contains text blocks.
 
         Note: Tool calls (ToolUseBlock/ToolResultBlock) are handled by hooks, not here.
@@ -105,7 +105,7 @@ async def _handle_assistant_message(self, message: AssistantMessage, msg_num: in
         # Stream text blocks to UI
         for block in message.content:
             if isinstance(block, TextBlock):
-                await self._handle_text_block(block, msg_num)
+                await self._handle_text_block(block)
 
         # Collect text for final response
         text_content = []
@@ -119,7 +119,7 @@ async def _handle_assistant_message(self, message: AssistantMessage, msg_num: in
                 "content": "\n".join(text_content)
             })
 
-    async def _handle_text_block(self, block: TextBlock, msg_num: int):
+    async def _handle_text_block(self, block: TextBlock):
         """Handle text content block."""
         if not block.text or not self.streaming_ctx:
             return