From fb9ca2c2704768dcd8b1b2d27741a2c043834f56 Mon Sep 17 00:00:00 2001
From: Étienne Loks <etienne.loks@iggdrasil.net>
Date: Fri, 13 Oct 2023 17:05:11 +0200
Subject: ✨ background task: set a low priority queue for imports
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ishtar_common/utils_celery.py | 9 +++++++++
 1 file changed, 9 insertions(+)
 create mode 100644 ishtar_common/utils_celery.py

(limited to 'ishtar_common/utils_celery.py')

diff --git a/ishtar_common/utils_celery.py b/ishtar_common/utils_celery.py
new file mode 100644
index 000000000..c2bf28ee9
--- /dev/null
+++ b/ishtar_common/utils_celery.py
@@ -0,0 +1,9 @@
+from kombu import Exchange, Queue
+
+
+def config_celery_queue(celery_conf):
+    task_queues = (
+        Queue('low_priority', Exchange('low_priority'), routing_key='low_priority'),
+        Queue('celery', Exchange('celery'), routing_key='celery'),
+    )
+    celery_conf.task_queues = task_queues
-- 
cgit v1.2.3