fix ruff import err

Author: srilaasya

agentops/instrumentation/agentic/xpander/context.py

@@ -33,7 +33,7 @@ def start_session(self, session_id: str, agent_info: Dict[str, Any], workflow_sp
                 self._workflow_spans[session_id] = workflow_span
             if agent_span:
                 self._agent_spans[session_id] = agent_span
-            
+
             # Initialize conversation counter
             self._conversation_counters[session_id] = 0
 
@@ -48,7 +48,7 @@ def end_conversation(self, session_id: str) -> None:
         with self._lock:
             if session_id in self._conversation_spans:
                 del self._conversation_spans[session_id]
-    
+
     def has_active_conversation(self, session_id: str) -> bool:
         """Check if there's an active conversation for this session."""
         with self._lock:
@@ -88,25 +88,25 @@ def get_workflow_phase(self, session_id: str) -> str:
         """Detect current workflow phase based on state."""
         with self._lock:
             session = self._sessions.get(session_id, {})
-            
-            if session.get('tools_executed', []):
+
+            if session.get("tools_executed", []):
                 return "executing"
-            elif session.get('step_count', 0) > 0:
+            elif session.get("step_count", 0) > 0:
                 return "executing"
             else:
                 return "planning"
-    
+
     def get_workflow_span(self, session_id: str):
         """Get the active workflow span for a session."""
         with self._lock:
             return self._workflow_spans.get(session_id)
-    
+
     def get_agent_span(self, session_id: str):
         """Get the active agent span for a session."""
         with self._lock:
             return self._agent_spans.get(session_id)
-    
+
     def get_conversation_span(self, session_id: str):
         """Get the active conversation span for a session."""
         with self._lock:
-            return self._conversation_spans.get(session_id)
+            return self._conversation_spans.get(session_id)

agentops/instrumentation/agentic/xpander/instrumentor.py

@@ -390,7 +390,7 @@ def wrapper(self, execution=None, input=None, **kwargs):
             elif execution is None:
                 # Neither execution nor input provided - create empty execution
                 execution = {}
-            
+
             # Extract session ID and agent info
             session_id = instrumentor._extract_session_id(execution)
             agent_name = getattr(self, "name", "unknown")

examples/xpander/coding_agent.py

@@ -3,6 +3,7 @@
 Modified to use AgentOps callback handlers for tool instrumentation.
 Single-file implementation combining MyAgent and XpanderEventListener.
 """
+# ruff: noqa: E402
 
 import asyncio
 import json