add

injection/data_sync/tasks.py

@@ -42,12 +42,6 @@ def write_to_es(es_type, pk_list, use_batch_query_set=False):
                 use_batch_query_set=use_batch_query_set,
                 es=ESPerform.get_cli()
             )
-
-        # # if es_type == 'topic':
-        #     auto_click(pk_list)
-        #     auto_reply(pk_list)
-
-
     except:
         logging.error("catch exception,err_msg:%s" % traceback.format_exc())
 

physical/celery_task_router.py

@@ -9,10 +9,7 @@ class CeleryTaskRouter(object):
     queue_task_map = {
         "tapir-alpha": [
             'injection.data_sync.tasks.write_to_es',
-        ],
-        # "majia-alpha": [
-        #     'injection.data_sync.tasks.auto_majia_effect',
-        # ],
+        ]
     }
 
     # Map[TaskName, QueueName]