diff --git a/libs/indice_pollution/indice_pollution/__init__.py b/libs/indice_pollution/indice_pollution/__init__.py
index ab280ad7..0750832a 100644
--- 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():