refactor: change mongodb update rules

shengchenyang · Oct 19, 2024 · 8af915f · 8af915f
1 parent 6bbb622
commit 8af915f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/ayugespidertools/common/mongodbpipe.py b/ayugespidertools/common/mongodbpipe.py
@@ -83,7 +83,7 @@ def _default_storage(
             if not item_dict.get("_mongo_update_rule"):
                 db[collection_name].insert_one(insert_data)
             else:
-                db[collection_name].update_many(
+                db[collection_name].update_one(
                     item_dict["_mongo_update_rule"], {"$set": insert_data}, True
                 )
 
@@ -166,7 +166,7 @@ async def _data_storage_logic(  # type: ignore[override]
         if not item_dict.get("_mongo_update_rule"):
             await db[collection_name].insert_one(insert_data)
         else:
-            await db[collection_name].update_many(
+            await db[collection_name].update_one(
                 item_dict["_mongo_update_rule"], {"$set": insert_data}, True
             )