modify

physical/celery_task_router.py

@@ -4,7 +4,7 @@ from __future__ import unicode_literals, print_function, absolute_import
 import itertools                                                                         
                                                                                          
 from django.conf import settings                                                         
-
+import logging
 
 class CeleryTaskRouter(object):
     queue_task_map = {
@@ -28,5 +28,6 @@ class CeleryTaskRouter(object):
             return "slow"
         """
 
+        logging.info("duan add,task is:%s" % str(task))
         queue_name_or_none = self.task_queue_map.get(task)
         return queue_name_or_none
\ No newline at end of file