add

physical/celery_task_router.py

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