Fix migration by using aggregation pipeline

webrecorder · Dec 1, 2023 · f3d05c8 · f3d05c8
1 parent f367616
commit f3d05c8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/backend/btrixcloud/migrations/migration_0023_available_extra_exec_mins.py b/backend/btrixcloud/migrations/migration_0023_available_extra_exec_mins.py
@@ -51,9 +51,9 @@ async def migrate_up(self):
         async for org in mdb_orgs.find({"monthlyExecSeconds": None}):
             oid = org["_id"]
             try:
-                await mdb_orgs.find_one_and_update(
+                await mdb_orgs.update_one(
                     {"_id": oid},
-                    {"$set": {"monthlyExecSeconds": "$crawlExecSeconds"}},
+                    [{"$set": {"monthlyExecSeconds": "$crawlExecSeconds"}}],
                 )
             # pylint: disable=broad-exception-caught
             except Exception as err: