fix

SocialGouv · Sep 11, 2023 · 0251e09 · 0251e09
1 parent dda90e5
commit 0251e09
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/libs/indice_pollution/indice_pollution/__init__.py b/libs/indice_pollution/indice_pollution/__init__.py
@@ -119,7 +119,7 @@ def setup_periodic_tasks(sender, **kwargs):
 
 def call_tasks_now():
     for task in all_tasks():
-        task.apply_async()
+        task.apply_async(queue='save_indices', routing_key='save_indices.save_all')
 
 
 def all_tasks():