ad

physical/celery_task_router.py

@@ -11,6 +11,7 @@ class CeleryTaskRouter(object):
     queue_task_map = {
         "tapir-alpha": [
             'injection.data_sync.tasks.write_to_es',
+            'injection.data_sync.write_to_es'
         ]
     }