Add priority to Task body

alephdata · Oct 2, 2023 · e53f8fb · e53f8fb
1 parent a308782
commit e53f8fb
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/servicelayer/taskqueue.py b/servicelayer/taskqueue.py
@@ -45,6 +45,7 @@ class Task:
     operation: str
     context: dict
     payload: dict
+    priority: int
     collection_id: Optional[str] = None
 
     @property
@@ -211,6 +212,7 @@ def get_task(body, delivery_tag) -> Task:
         operation=body["operation"],
         context=body["context"] or {},
         payload=body["payload"] or {},
+        priority=body["priority"] or 0,
     )