modify

physical/celery_task_router.py

@@ -8,7 +8,7 @@ from django.conf import settings
 
 class CeleryTaskRouter(object):
     queue_task_map = {
-        "gaia-dbmw":{
+        "tapir-alpha":{
             'injection.data_sync.tasks.write_to_es',
         }
     }