Refactor code formatting and enhance error handling in orchestration tasks

Author: Kingshuk-Microsoft

src/backend/v3/api/router.py

@@ -307,10 +307,10 @@ async def process_request(
 
         async def run_orchestration_task():
             await OrchestrationManager.get_current_or_new_orchestration(
-              user_id=user_id,
-              team_config=team_config,
-              team_switched=False,
-          )
+                user_id=user_id,
+                team_config=team_config,
+                team_switched=False,
+            )
             await OrchestrationManager().run_orchestration(user_id, input_task)
 
         background_tasks.add_task(run_orchestration_task)
@@ -337,12 +337,11 @@ async def run_orchestration_task():
 
 @app_v3.post("/plan_approval")
 async def plan_approval(human_feedback: messages.PlanApprovalResponse, request: Request):
-    
     authenticated_user = get_authenticated_user_details(request_headers=request.headers)
     user_id = authenticated_user["user_principal_id"]
     if not user_id:
         raise HTTPException(
-          status_code=401, detail="Missing or invalid user information"
+            status_code=401, detail="Missing or invalid user information"
         )
     # Set the approval in the orchestration config
     try:

src/backend/v3/models/messages.py

@@ -215,4 +215,3 @@ class WebsocketMessageType(str, Enum):
     FINAL_RESULT_MESSAGE = "final_result_message"
     TIMEOUT_NOTIFICATION = "timeout_notification"
     ERROR_MESSAGE = "error_message"
-    

src/backend/v3/orchestration/orchestration_manager.py

@@ -99,7 +99,7 @@ async def callback(
             except Exception as e:
                 logger = logging.getLogger(f"{__name__}.OrchestrationManager")
                 logger.error(f"Error in streaming agent response callback: {e}")
-                
+
         return callback
 
     @classmethod