Prevent duplicate team agents and update agent retrieval

Ensures no duplicate team agents are added by deleting existing entries before insertion in CosmosDBClient. Updates SQL query to select all fields for team agent retrieval. Refactors agent initialization in lifecycle.py to use correct parameter names and agent ID source, and adds a note to narrow exception handling.

Author: Fr4nc3

src/backend/common/database/cosmosdb.py

@@ -495,6 +495,7 @@ async def get_agent_messages(self, plan_id: str) -> List[AgentMessageData]:
 
     async def add_team_agent(self, team_agent: CurrentTeamAgent) -> None:
         """Add an agent message to the database."""
+        await self.delete_team_agent(team_agent.team_id, team_agent.agent_name) # Ensure no duplicates
         await self.add_item(team_agent)
 
     async def delete_team_agent(self, team_id: str, agent_name: str) -> None:
@@ -525,7 +526,7 @@ async def get_team_agent(
         self, team_id: str, agent_name: str
     ) -> Optional[CurrentTeamAgent]:
         """Retrieve a team agent by team_id and agent_name."""
-        query = "SELECT c.id, c.session_id FROM c WHERE c.team_id=@team_id AND c.data_type=@data_type AND c.agent_name=@agent_name"
+        query = "SELECT * FROM c WHERE c.team_id=@team_id AND c.data_type=@data_type AND c.agent_name=@agent_name"
         params = [
             {"name": "@team_id", "value": team_id},
             {"name": "@agent_name", "value": agent_name},

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

@@ -143,10 +143,10 @@ async def get_database_team_agent(self) -> Optional[CurrentTeamAgent]:
             )
             if currentAgent and currentAgent.agent_foundry_id:
                 agent = self.client.get_agent(
-                    id=currentAgent.agent_foundry_id
+                    agent_id=currentAgent.agent_foundry_id
                 )
 
-        except Exception as ex:
+        except Exception as ex:  # Consider narrowing this to specific exceptions if possible
             self.logger.error("Failed to initialize ReasoningAgentTemplate: %s", ex)
         return agent
 
@@ -157,7 +157,7 @@ async def save_database_team_agent(self) -> None:
                 team_id=self.team_config.team_id,
                 team_name=self.team_config.name,
                 agent_name=self.agent_name,
-                agent_foundry_id=self._agent.id,
+                agent_foundry_id=self._agent.chat_client.agent_id,
                 agent_description=self.agent_description,
                 agent_instructions=self.agent_instructions,
             )