|
@@ -760,7 +760,6 @@ class NewContentIdTask(object):
|
|
|
:return:
|
|
:return:
|
|
|
"""
|
|
"""
|
|
|
task_list = await self.get_tasks()
|
|
task_list = await self.get_tasks()
|
|
|
- print(task_list)
|
|
|
|
|
task_dict = {}
|
|
task_dict = {}
|
|
|
# 对 content_id去重
|
|
# 对 content_id去重
|
|
|
for task in task_list:
|
|
for task in task_list:
|
|
@@ -776,6 +775,7 @@ class NewContentIdTask(object):
|
|
|
)
|
|
)
|
|
|
if task_list:
|
|
if task_list:
|
|
|
total_task = len(process_list)
|
|
total_task = len(process_list)
|
|
|
|
|
+ print(process_list)
|
|
|
a = time.time()
|
|
a = time.time()
|
|
|
print("开始处理，一共{}个任务".format(total_task))
|
|
print("开始处理，一共{}个任务".format(total_task))
|
|
|
tasks = [self.process_task(params) for params in process_list]
|
|
tasks = [self.process_task(params) for params in process_list]
|
