|
@@ -810,7 +810,7 @@ class NewContentIdTask(object):
|
|
|
print(process_list)
|
|
|
a = time.time()
|
|
|
print("开始处理,一共{}个任务".format(total_task))
|
|
|
- tasks = [self.process_task(params) for params in process_list[:1]]
|
|
|
+ tasks = [self.process_task(params) for params in process_list]
|
|
|
await asyncio.gather(*tasks)
|
|
|
b = time.time()
|
|
|
print("处理时间: {} s".format(b - a))
|