add

injection/data_sync/tasks.py

@@ -109,6 +109,12 @@ def sync_user_similar_score():
     except:
         logging.error("catch exception,err_msg:%s" % traceback.format_exc())
 
+@shared_task
+def auto_majia_effect(pk_list):
+    logging.info("get -----auto_majia_effect----")
+    auto_click(pk_list)
+    auto_reply(pk_list)
+
 
 def auto_click(pk_list):
     logging.info("get--------auto_click--------------:%s" % pk_list)

physical/celery_task_router.py

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