Skip to content
Snippets Groups Projects
Commit 99e9b476 authored by Alessandro Cerioni's avatar Alessandro Cerioni
Browse files

Ordered -> unordered MongoDB bulk write operations.

parent 15b6f1dd
Branches
Tags v1.2.4
No related merge requests found
......@@ -29,7 +29,7 @@ def process_doc_pages( channel, method, properties, body, mongodb ):
bulk_write_operations.append(ReplaceOne({'_id': doc['_id']}, doc, upsert=True))
# execute bulk write
res = collection.bulk_write( bulk_write_operations )
res = collection.bulk_write( bulk_write_operations, ordered=False )
if res.acknowledged == True:
channel.basic_ack(delivery_tag = method.delivery_tag)
else:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment