|
@@ -132,7 +132,7 @@ class ItemBuffer(threading.Thread):
|
|
|
elif isinstance(data, FailedTaskItem):
|
|
|
data.queue_name = self._tab_items # 采集任务队列名称
|
|
|
failed_times = data.to_dict.pop('failed_times', 0)
|
|
|
- if failed_times >= setting.SPIDER_FAILED_TASK_MAX_RETRY_TIMES:
|
|
|
+ if failed_times >= setting.SPIDER_MAX_RETRY_TIMES:
|
|
|
state = 4 # 待采集任务停止采集状态[4=停止采集]
|
|
|
# 更新完成采集的任务状态
|
|
|
update_item = UpdateItem(
|