Anony331
diff --git a/Collapse file
‎feapder/buffer/item_buffer.py‎
Copy file name to clipboardExpand all lines: feapder/buffer/item_buffer.py
+9-1Lines changed: 9 additions & 1 deletion b/Collapse file
‎feapder/buffer/item_buffer.py‎
Copy file name to clipboardExpand all lines: feapder/buffer/item_buffer.py
+9-1Lines changed: 9 additions & 1 deletion
diff --git a/Collapse file
‎feapder/pipelines/mysql_pipeline.py‎
Copy file name to clipboardExpand all lines: feapder/pipelines/mysql_pipeline.py
+2-6Lines changed: 2 additions & 6 deletions b/Collapse file
‎feapder/pipelines/mysql_pipeline.py‎
Copy file name to clipboardExpand all lines: feapder/pipelines/mysql_pipeline.py
+2-6Lines changed: 2 additions & 6 deletions
@@ -269,7 +269,15 @@ def __export_to_db(self, tab_item, datas, is_update=False, update_keys=()):
 
         # 若是任务表, 且上面的pipeline里没mysql，则需调用mysql更新任务
         if not self._have_mysql_pipeline and is_update and to_table == self._task_table:
-            self.mysql_pipeline.update_items(to_table, datas, update_keys=update_keys)
+            if not self.mysql_pipeline.update_items(
+                to_table, datas, update_keys=update_keys
+            ):
+                log.error(
+                    f"{pipeline.__class__.__name__} 更新数据失败. table: {to_table}  items: {datas}"
+                )
+                return False
+
+        return True
 
     def __add_item_to_db(
         self, items, update_items, requests, callbacks, items_fingerprints
 
@@ -41,9 +41,7 @@ def save_items(self, table, items: List[Dict]) -> bool:
         sql, datas = tools.make_batch_sql(table, items)
         add_count = self.to_db.add_batch(sql, datas)
         datas_size = len(datas)
-        if add_count is None:
-            log.error("导出数据到表 %s 失败" % (table))
-        else:
+        if add_count:
             log.info(
                 "共导出 %s 条数据 到 %s, 重复 %s 条" % (datas_size, table, datas_size - add_count)
             )
@@ -67,9 +65,7 @@ def update_items(self, table, items: List[Dict], update_keys=Tuple) -> bool:
             table, items, update_columns=update_keys or list(items[0].keys())
         )
         update_count = self.to_db.add_batch(sql, datas)
-        if update_count is None:
-            log.error("更新表 %s 数据失败" % (table))
-        else:
+        if update_count:
             msg = "共更新 %s 条数据 到 %s" % (update_count // 2, table)
             if update_keys:
                 msg += " 更新字段为 {}".format(update_keys)