From 33b2cefb567a484300363dbe4a4236188f4afbec Mon Sep 17 00:00:00 2001 From: Olivier Desenfans Date: Wed, 27 Apr 2022 12:24:03 +0200 Subject: [PATCH] [Fix] Use collection of DB op in bulk write --- src/aleph/jobs/process_pending_messages.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/aleph/jobs/process_pending_messages.py b/src/aleph/jobs/process_pending_messages.py index 614564da3..9028431a3 100644 --- a/src/aleph/jobs/process_pending_messages.py +++ b/src/aleph/jobs/process_pending_messages.py @@ -66,7 +66,7 @@ async def join_pending_message_tasks(tasks): for collection, operations in groupby(db_operations, lambda op: op.collection): mongo_ops = [op.operation for op in operations] - await collection.bulk_write(mongo_ops) + await collection.collection.bulk_write(mongo_ops) tasks.clear()