|
@@ -178,14 +178,15 @@ class ItemBuffer(threading.Thread):
|
|
|
data.state = 1 # 待采集任务等待采集状态[1=等待采集]
|
|
|
|
|
|
elif isinstance(data, BaseDetailItem):
|
|
|
- update_item = UpdateItem(
|
|
|
- state=2, # 待采集任务成功采集状态[2=完成采集]
|
|
|
- pyuuid=data.pyuuid,
|
|
|
- update_at=update_at,
|
|
|
- )
|
|
|
- update_item.update_key = ['state', 'update_at']
|
|
|
- update_item.table_name = setting.TASK_REQUEST_PRODUCE
|
|
|
- update_items.append(update_item)
|
|
|
+ if not getattr(data, "is_mixed"):
|
|
|
+ update_item = UpdateItem(
|
|
|
+ state=2, # 待采集任务成功采集状态[2=完成采集]
|
|
|
+ pyuuid=data.pyuuid,
|
|
|
+ update_at=update_at,
|
|
|
+ )
|
|
|
+ update_item.update_key = ['state', 'update_at']
|
|
|
+ update_item.table_name = setting.TASK_REQUEST_PRODUCE
|
|
|
+ update_items.append(update_item)
|
|
|
|
|
|
if data.dont_save:
|
|
|
# 不保存数据
|