Remove noqa: BLE001 comments from exception handlers

Eliminated all '# noqa: BLE001' comments from exception handling blocks across multiple modules. This change improves code cleanliness and removes unnecessary linter suppression comments.

Author: Fr4nc3

src/backend/af/callbacks/response_handlers.py

@@ -95,7 +95,7 @@ def agent_response_callback(
             )
         )
         logger.info("%s message (agent=%s): %s", str(role).capitalize(), agent_name, text[:200])
-    except Exception as e:  # noqa: BLE001
+    except Exception as e:  
         logger.error("agent_response_callback error sending WebSocket message: %s", e)
 
 
@@ -148,5 +148,5 @@ async def streaming_agent_response_callback(
                 message_type=WebsocketMessageType.AGENT_MESSAGE_STREAMING,
             )
             logger.debug("Streaming chunk (agent=%s final=%s len=%d)", agent_id, is_final, len(cleaned))
-    except Exception as e:  # noqa: BLE001
+    except Exception as e:  
         logger.error("streaming_agent_response_callback error: %s", e)

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

@@ -56,12 +56,12 @@ async def close(self) -> None:
             if self._agent and hasattr(self._agent, "close"):
                 try:
                     await self._agent.close()  # AzureAIAgentClient has async close
-                except Exception:  # noqa: BLE001
+                except Exception:  
                     pass
             # Unregister from registry if present
             try:
                 agent_registry.unregister_agent(self)
-            except Exception:  # noqa: BLE001
+            except Exception:  
                 pass
             await self._stack.aclose()
         finally:
@@ -98,7 +98,7 @@ async def _prepare_mcp_tool(self) -> None:
             )
             await self._stack.enter_async_context(mcp_tool)
             self.mcp_tool = mcp_tool  # Store for later use
-        except Exception:  # noqa: BLE001
+        except Exception:  
             self.mcp_tool = None
 
 
@@ -154,7 +154,7 @@ async def open(self) -> "AzureAgentBase":
         # Register agent (best effort)
         try:
             agent_registry.register_agent(self)
-        except Exception:  # noqa: BLE001
+        except Exception:  
             pass
 
         return self
@@ -178,25 +178,25 @@ async def close(self) -> None:
             if self._agent and hasattr(self._agent, "close"):
                 try:
                     await self._agent.close()
-                except Exception:  # noqa: BLE001
+                except Exception:  
                     pass
 
             # Unregister from registry
             try:
                 agent_registry.unregister_agent(self)
-            except Exception:  # noqa: BLE001
+            except Exception:  
                 pass
 
             # Close credential and project client
             if self.client:
                 try:
                     await self.client.close()
-                except Exception:  # noqa: BLE001
+                except Exception:  
                     pass
             if self.creds:
                 try:
                     await self.creds.close()
-                except Exception:  # noqa: BLE001
+                except Exception:  
                     pass
 
         finally:

src/backend/af/magentic_agents/proxy_agent.py

@@ -164,7 +164,7 @@ async def _wait_for_user_clarification(
         except KeyError:
             logger.debug("ProxyAgentAF: Invalid clarification request id %s", request_id)
             return None
-        except Exception as ex:  # noqa: BLE001
+        except Exception as ex:  
             logger.debug("ProxyAgentAF: Unexpected error awaiting clarification: %s", ex)
             orchestration_config.cleanup_clarification(request_id)
             return None
@@ -199,7 +199,7 @@ async def _notify_timeout(self, request_id: str) -> None:
                 request_id,
                 self.user_id,
             )
-        except Exception as ex:  # noqa: BLE001
+        except Exception as ex:  
             logger.error("ProxyAgentAF: Failed to send timeout notification: %s", ex)
         orchestration_config.cleanup_clarification(request_id)
 

src/backend/af/magentic_agents/reasoning_agent.py

@@ -152,7 +152,7 @@ async def close(self) -> None:
             # Unregister from registry
             try:
                 agent_registry.unregister_agent(self)
-            except Exception:  # noqa: BLE001
+            except Exception:  
                 pass
 
         finally:

src/backend/af/orchestration/human_approval_manager.py

@@ -121,7 +121,7 @@ async def plan(self, magentic_context: MagenticContext) -> Any:
 
         try:
             orchestration_config.plans[self.magentic_plan.id] = self.magentic_plan
-        except Exception as e:  # noqa: BLE001
+        except Exception as e:  
             logger.error("Error processing plan approval: %s", e)
 
         # Send approval request
@@ -242,13 +242,13 @@ async def _wait_for_user_approval(
                     self.current_user_id,
                     m_plan_id,
                 )
-            except Exception as e:  # noqa: BLE001
+            except Exception as e:  
                 logger.error("Failed to send timeout notification: %s", e)
 
             orchestration_config.cleanup_approval(m_plan_id)
             return None
 
-        except KeyError as e:  # noqa: BLE001
+        except KeyError as e:  
             logger.debug("Plan ID not found: %s - terminating process silently", e)
             return None
 
@@ -257,7 +257,7 @@ async def _wait_for_user_approval(
             orchestration_config.cleanup_approval(m_plan_id)
             return None
 
-        except Exception as e:  # noqa: BLE001
+        except Exception as e:  
             logger.debug(
                 "Unexpected error waiting for approval: %s - terminating process silently",
                 e,

src/backend/common/utils/utils_af.py

@@ -41,7 +41,7 @@ async def create_RAI_agent() -> FoundryAgentTemplate:
 
     try:
         agent_registry.register_agent(agent)
-    except Exception as registry_error:  # noqa: BLE001
+    except Exception as registry_error:  
         logging.warning(
             "Failed to register agent '%s' with registry: %s",
             agent.agent_name,
@@ -72,7 +72,7 @@ async def _get_agent_response(agent: FoundryAgentTemplate, query: str) -> str:
                     if txt:
                         parts.append(str(txt))
         return "".join(parts) if parts else ""
-    except Exception as e:  # noqa: BLE001
+    except Exception as e:  
         logging.error("Error streaming agent response: %s", e)
         return "TRUE"  # Default to blocking on error
 
@@ -99,15 +99,15 @@ async def rai_success(description: str) -> bool:
             logging.info("RAI check failed (blocked). Sample: %s...", description[:60])
             return False
 
-    except Exception as e:  # noqa: BLE001
+    except Exception as e:  
         logging.error("RAI check error: %s — blocking by default.", e)
         return False
     finally:
         # Ensure we close resources
         if agent:
             try:
                 await agent.close()
-            except Exception:  # noqa: BLE001
+            except Exception:  
                 pass
 
 
@@ -160,6 +160,6 @@ async def rai_validate_team_config(team_config_json: dict) -> tuple[bool, str]:
             )
 
         return True, ""
-    except Exception as e:  # noqa: BLE001
+    except Exception as e:  
         logging.error("Error validating team configuration content: %s", e)
         return False, "Unable to validate team configuration content. Please try again."