resolved pylint issues

Author: Abdul-Microsoft

src/backend/app.py

@@ -10,7 +10,7 @@
 
 
 from azure.monitor.opentelemetry import configure_azure_monitor
-#from common.config.app_config import config
+# from common.config.app_config import config
 from common.models.messages_af import UserLanguage
 
 # FastAPI imports
@@ -66,7 +66,7 @@ async def lifespan(app: FastAPI):
     )
 
 # Configure logging levels from environment variables
-#logging.basicConfig(level=getattr(logging, config.AZURE_BASIC_LOGGING_LEVEL.upper(), logging.INFO))
+# logging.basicConfig(level=getattr(logging, config.AZURE_BASIC_LOGGING_LEVEL.upper(), logging.INFO))
 
 # Configure Azure package logging levels
 azure_level = getattr(logging, config.AZURE_PACKAGE_LOGGING_LEVEL.upper(), logging.WARNING)

src/backend/v4/callbacks/response_handlers.py

@@ -121,7 +121,7 @@ async def streaming_agent_response_callback(
     try:
         # Handle various streaming update object shapes
         chunk_text = getattr(update, "text", None)
-        
+
         # If text is None, don't fall back to str(update) as that would show object repr
         # Just skip if there's no actual text content
         if chunk_text is None:

src/backend/v4/magentic_agents/common/lifecycle.py

@@ -149,7 +149,7 @@ async def _after_open(self) -> None:
 
     def get_chat_client(self) -> AzureAIClient:
         """Return the underlying ChatClientProtocol (AzureAIClient).
-        
+
         Uses agent_name with use_latest_version=True to get the latest agent version.
         Agent reuse is handled automatically by the SDK via agent_name.
         """
@@ -173,7 +173,7 @@ def get_chat_client(self) -> AzureAIClient:
 
     def get_agent_id(self) -> str:
         """Generate a local agent ID for the ChatAgent wrapper.
-        
+
         The new AzureAIClient identifies agents by name (not ID) on the server side.
         This ID is only used locally for the ChatAgent wrapper instance.
         """

src/backend/v4/magentic_agents/foundry_agent.py

@@ -174,7 +174,6 @@ async def _create_azure_search_enabled_client(self) -> Optional[AzureAIClient]:
                 f"{self.agent_instructions} "
                 "Always use the Azure AI Search tool and configured index for knowledge retrieval."
             )
-            
 
             azure_agent = await self.project_client.agents.create_version(
                 agent_name=self.agent_name,  # Use original name

src/backend/v4/orchestration/human_approval_manager.py

@@ -85,7 +85,7 @@ def __init__(self, user_id: str, agent, *args, **kwargs):
             ORCHESTRATOR_TASK_LEDGER_PLAN_UPDATE_PROMPT + plan_append
         )
         kwargs["final_answer_prompt"] = ORCHESTRATOR_FINAL_ANSWER_PROMPT + final_append
-        
+
         # Override progress ledger prompt to discourage re-calling agents
         from agent_framework._workflows._magentic import ORCHESTRATOR_PROGRESS_LEDGER_PROMPT
         kwargs["progress_ledger_prompt"] = ORCHESTRATOR_PROGRESS_LEDGER_PROMPT + progress_append
@@ -319,4 +319,4 @@ def plan_to_obj(self, magentic_context: MagenticContext, ledger) -> MPlan:
             task=task_text,
         )
 
-        return return_plan
+        return return_plan

src/backend/v4/orchestration/orchestration_manager.py

@@ -50,7 +50,7 @@ def __init__(self):
     def _extract_response_text(self, data) -> str:
         """
         Extract text content from various agent_framework response types.
-        
+
         Handles:
         - ChatMessage: Extract .text
         - AgentResponse: Extract .text
@@ -59,15 +59,15 @@ def _extract_response_text(self, data) -> str:
         """
         if data is None:
             return ""
-        
+
         # Direct ChatMessage
         if isinstance(data, ChatMessage):
             return data.text or ""
-        
+
         # Has .text attribute directly (AgentResponse, etc.)
         if hasattr(data, "text") and data.text:
             return data.text
-        
+
         # AgentExecutorResponse - has agent_response and full_conversation
         if hasattr(data, "agent_response"):
             # Try to get text from agent_response first
@@ -79,7 +79,7 @@ def _extract_response_text(self, data) -> str:
                 last_msg = data.full_conversation[-1]
                 if isinstance(last_msg, ChatMessage) and last_msg.text:
                     return last_msg.text
-        
+
         # List of items - could be AgentExecutorResponse, ChatMessage, etc.
         if isinstance(data, list) and len(data) > 0:
             texts = []
@@ -91,7 +91,7 @@ def _extract_response_text(self, data) -> str:
             if texts:
                 # Return the last non-empty response (most recent)
                 return texts[-1]
-        
+
         return ""
 
     # ---------------------------
@@ -195,12 +195,12 @@ async def init_orchestration(
 
         # Assemble workflow with callback
         storage = InMemoryCheckpointStorage()
-        
+
         # New SDK: participants() accepts a Sequence (list) of agents
         # The orchestrator uses agent.name to identify them
         participant_list = list(participants.values())
         cls.logger.info("Participants for workflow: %s", list(participants.keys()))
-        
+
         builder = (
             MagenticBuilder()
             .participants(participant_list)  # New SDK: pass as list
@@ -241,7 +241,7 @@ async def get_current_or_new_orchestration(
         """
         current = orchestration_config.get_current_orchestration(user_id)
         needs_rebuild = current is None or team_switched or force_rebuild
-        
+
         if needs_rebuild:
             if current is not None and (team_switched or force_rebuild):
                 reason = "team switched" if team_switched else "force rebuild for new task"
@@ -387,7 +387,7 @@ async def run_orchestration(self, user_id: str, input_task) -> None:
                     event_type_name = type(event).__name__
                     if event_type_name != "AgentRunUpdateEvent":
                         self.logger.info("[EVENT] %s", event_type_name)
-                    
+
                     # Handle orchestrator events (plan, progress ledger)
                     if isinstance(event, MagenticOrchestratorEvent):
                         self.logger.info(
@@ -403,7 +403,7 @@ async def run_orchestration(self, user_id: str, input_task) -> None:
                     elif isinstance(event, AgentRunUpdateEvent):
                         message_id = event.data.message_id if hasattr(event.data, 'message_id') else None
                         executor_id = event.executor_id
-                        
+
                         # Stream the update
                         try:
                             await streaming_agent_response_callback(
@@ -417,7 +417,7 @@ async def run_orchestration(self, user_id: str, input_task) -> None:
                                 "Error in streaming callback for agent %s: %s",
                                 executor_id, e
                             )
-                        
+
                         # Track message for formatting
                         if message_id != last_message_id:
                             last_message_id = message_id
@@ -427,14 +427,14 @@ async def run_orchestration(self, user_id: str, input_task) -> None:
                         agent_name = event.participant_name
                         agent_call_counts[agent_name] = agent_call_counts.get(agent_name, 0) + 1
                         call_num = agent_call_counts[agent_name]
-                        
+
                         self.logger.info(
                             "[REQUEST SENT (round %d)] to agent: %s (call #%d)",
                             event.round_index,
                             agent_name,
                             call_num
                         )
-                        
+
                         if call_num > 1:
                             self.logger.warning("Agent '%s' called %d times", agent_name, call_num)
 
@@ -448,7 +448,7 @@ async def run_orchestration(self, user_id: str, input_task) -> None:
                         # Send the agent response to the UI
                         if event.data:
                             response_text = self._extract_response_text(event.data)
-                            
+
                             if response_text:
                                 self.logger.info("Sending agent response to UI from %s", event.participant_name)
                                 agent_response_callback(