diff options
| 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 |
| commit | b6651d3cafc1b7079db67140bf1e3746e919c73b (patch) | |
| tree | 50e910978eed1e7c3ca61c6097c0bb9bc5921a1e /ishtar_common/utils_celery.py | |
| parent | c990705c81885dcfbcafb11c8ecd368755ac8607 (diff) | |
| download | Ishtar-b6651d3cafc1b7079db67140bf1e3746e919c73b.tar.bz2 Ishtar-b6651d3cafc1b7079db67140bf1e3746e919c73b.zip | |
✨ background task: set a low priority queue for imports
Diffstat (limited to 'ishtar_common/utils_celery.py')
| -rw-r--r-- | ishtar_common/utils_celery.py | 9 |
1 files changed, 9 insertions, 0 deletions
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 |