summaryrefslogtreecommitdiff
path: root/ishtar_common/models_common.py
diff options
context:
space:
mode:
authorÉtienne Loks <etienne.loks@iggdrasil.net>2023-10-13 17:05:11 +0200
committerÉtienne Loks <etienne.loks@iggdrasil.net>2024-04-16 16:37:12 +0200
commitb6651d3cafc1b7079db67140bf1e3746e919c73b (patch)
tree50e910978eed1e7c3ca61c6097c0bb9bc5921a1e /ishtar_common/models_common.py
parentc990705c81885dcfbcafb11c8ecd368755ac8607 (diff)
downloadIshtar-b6651d3cafc1b7079db67140bf1e3746e919c73b.tar.bz2
Ishtar-b6651d3cafc1b7079db67140bf1e3746e919c73b.zip
✨ background task: set a low priority queue for imports
Diffstat (limited to 'ishtar_common/models_common.py')
-rw-r--r--ishtar_common/models_common.py2
1 files changed, 2 insertions, 0 deletions
diff --git a/ishtar_common/models_common.py b/ishtar_common/models_common.py
index bde457a3c..ccc70d81c 100644
--- a/ishtar_common/models_common.py
+++ b/ishtar_common/models_common.py
@@ -3340,6 +3340,7 @@ class MainItem(ShortMenuItem, SerializeItem):
return
if getattr(self, "_no_down_model_update", False):
return
+ queue = getattr(self, "_queue", settings.CELERY_DEFAULT_QUEUE)
for down_model in self.DOWN_MODEL_UPDATE:
if not settings.USE_BACKGROUND_TASK:
rel = getattr(self, down_model)
@@ -3349,6 +3350,7 @@ class MainItem(ShortMenuItem, SerializeItem):
for item in getattr(self, down_model).all():
if hasattr(self, "_timestamp"):
item._timestamp = self._timestamp
+ item._queue = queue
if hasattr(item, "cached_label_changed"):
item.cached_label_changed()
if hasattr(item, "main_geodata"):