From dee0bcdcead02dccecd47467634973738886fd1e Mon Sep 17 00:00:00 2001 From: LennartSchmidtKern Date: Mon, 9 Mar 2026 11:36:33 +0100 Subject: [PATCH] fix: Reintroduce priority queue task arg --- controller/data_block/manager.py | 1 - controller/task_master/manager.py | 4 ++-- fast_api/routes/project_setting.py | 2 +- 3 files changed, 3 insertions(+), 4 deletions(-) diff --git a/controller/data_block/manager.py b/controller/data_block/manager.py index 5b3b6b6f..4cd2ba4a 100644 --- a/controller/data_block/manager.py +++ b/controller/data_block/manager.py @@ -99,7 +99,6 @@ def update_query_results( "project_id": str(data_block.project_id), "task_list": task_list, }, - project_id=str(data_block.project_id), ) return results diff --git a/controller/task_master/manager.py b/controller/task_master/manager.py index f44c2096..5d7a7675 100644 --- a/controller/task_master/manager.py +++ b/controller/task_master/manager.py @@ -11,7 +11,7 @@ def queue_task( user_id: str, task_type: enums.TaskType, task_info: Union[List[Dict[str, Any]], Dict[str, Any]], - project_id: Optional[str] = None, + priority: bool = False, ) -> requests.Response: task_payload = { @@ -19,7 +19,7 @@ def queue_task( "userId": user_id, "taskType": task_type.value, "taskInfo": task_info, - "projectId": project_id, + "priority": priority, } return requests.put(f"{TASK_MASTER_URL}/task/queue", json=task_payload) diff --git a/fast_api/routes/project_setting.py b/fast_api/routes/project_setting.py index 28735fe5..cf6ea020 100644 --- a/fast_api/routes/project_setting.py +++ b/fast_api/routes/project_setting.py @@ -248,7 +248,7 @@ def calculate_user_attribute_all_records( "attribute_id": str(body.attribute_id), "data_block_id": body.data_block_id, }, - True, + priority=True, ) return get_silent_success()