From 45af66c6f31b74b4581e734a5dd1592637cd37df Mon Sep 17 00:00:00 2001 From: Dhruvkumar-Microsoft Date: Fri, 19 Sep 2025 16:41:04 +0530 Subject: [PATCH] Added the user_id explicitly to get the completed task --- src/backend/common/database/cosmosdb.py | 4 ++-- src/backend/common/database/database_base.py | 2 +- src/backend/v3/api/router.py | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/backend/common/database/cosmosdb.py b/src/backend/common/database/cosmosdb.py index 956d5025e..90f5a66e4 100644 --- a/src/backend/common/database/cosmosdb.py +++ b/src/backend/common/database/cosmosdb.py @@ -235,11 +235,11 @@ async def get_all_plans_by_team_id(self, team_id: str) -> List[Plan]: return await self.query_items(query, parameters, Plan) - async def get_all_plans_by_team_id_status(self, team_id: str, status: str) -> List[Plan]: + async def get_all_plans_by_team_id_status(self, user_id: str,team_id: str, status: str) -> List[Plan]: """Retrieve all plans for a specific team.""" query = "SELECT * FROM c WHERE c.team_id=@team_id AND c.data_type=@data_type and c.user_id=@user_id and c.overall_status=@status ORDER BY c._ts DESC" parameters = [ - {"name": "@user_id", "value": self.user_id}, + {"name": "@user_id", "value": user_id}, {"name": "@team_id", "value": team_id}, {"name": "@data_type", "value": DataType.plan}, {"name": "@status", "value": status}, diff --git a/src/backend/common/database/database_base.py b/src/backend/common/database/database_base.py index 30f173004..24327ee67 100644 --- a/src/backend/common/database/database_base.py +++ b/src/backend/common/database/database_base.py @@ -93,7 +93,7 @@ async def get_all_plans_by_team_id(self, team_id: str) -> List[Plan]: @abstractmethod async def get_all_plans_by_team_id_status( - self, team_id: str, status: str + self, user_id:str, team_id: str, status: str ) -> List[Plan]: """Retrieve all plans for a specific team.""" pass diff --git a/src/backend/v3/api/router.py b/src/backend/v3/api/router.py index cb65f85d4..f3e6fa436 100644 --- a/src/backend/v3/api/router.py +++ b/src/backend/v3/api/router.py @@ -1214,7 +1214,7 @@ async def get_plans(request: Request): return [] all_plans = await memory_store.get_all_plans_by_team_id_status( - team_id=current_team.team_id, status=PlanStatus.completed + user_id=user_id, team_id=current_team.team_id, status=PlanStatus.completed ) return all_plans