删掉return和日志

injection/data_sync/tasks.py

@@ -38,6 +38,4 @@ def write_to_es(es_type, pk_list, use_batch_query_set=False):
             )
 
     except:
-        logging.error("catch exception,err_msg:%s" % traceback.format_exc())
-    finally:
+        logging.error("catch exception,err_msg:%s" % traceback.format_exc())
\ No newline at end of file
-        return es_type,

search_tips/celery_task_router.py

@@ -18,8 +18,6 @@ class CeleryTaskRouter(object):
         for (queue, task_list) in queue_task_map.items()
     ))
 
-    logging.info("task_queue_map:%s" % task_queue_map)
-
     def route_for_task(self, task, args=None, kwargs=None):
         """
         if settings.DEBUG:
@@ -30,5 +28,4 @@ class CeleryTaskRouter(object):
         """
 
         queue_name_or_none = self.task_queue_map.get(task)
-        logging.info("task_queue_map:%s" % queue_name_or_none)
         return queue_name_or_none