fix: Reintroduce priority queue task arg (#395)

LennartSchmidtKern · JWittmeyer · web-flow · commit e92d5f2a7534 · 2026-03-10T10:56:58.000+01:00
Co-authored-by: JWittmeyer &lt;91723236+JWittmeyer@users.noreply.github.com&gt;
diff --git 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
@@ -11,15 +11,15 @@ 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 = {
         "orgId": org_id,
         "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
@@ -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()

Original file line number	Diff line number	Diff line change
`@@ -99,7 +99,6 @@ def update_query_results(`
`99`	`99`	`"project_id": str(data_block.project_id),`
`100`	`100`	`"task_list": task_list,`
`101`	`101`	`},`
`102`		`- project_id=str(data_block.project_id),`
`103`	`102`	`)`
`104`	`103`	`return results`
`105`	`104`
Original file line number	Diff line number	Diff line change
`@@ -248,7 +248,7 @@ def calculate_user_attribute_all_records(`
`248`	`248`	`"attribute_id": str(body.attribute_id),`
`249`	`249`	`"data_block_id": body.data_block_id,`
`250`	`250`	`},`
`251`		`- True,`
	`251`	`+ priority=True,`
`252`	`252`	`)`
`253`	`253`
`254`	`254`	`return get_silent_success()`