newContentIdTask.py

add info: 每次任务获取任务数量详情

tasks/newContentIdTask.py

@@ -754,12 +754,17 @@ class NewContentIdTask(object):
             process_list.append(task_dict[item])
         logging(
             code="5001",
-            info="Match Task Got {} this time".format(len(task_list)),
+            info="Match Task Got {} this time".format(len(process_list)),
             function="Publish Task"
         )
         if task_list:
+            total_task = len(process_list)
+            a = time.time()
+            print("开始处理，一共{}个任务".format(total_task))
             tasks = [self.process_task(params) for params in process_list]
             await asyncio.gather(*tasks)
+            b = time.time()
+            print("处理时间: {} s".format(b - a))
         else:
             logging(
                 code="9008",