From 8966572d5b3bae4a41b56e5289ef1b7f8a4690ba Mon Sep 17 00:00:00 2001 From: prijendev Date: Fri, 20 Dec 2024 16:14:23 +0530 Subject: [PATCH] Add applyOps in the projection query --- tap_mongodb/sync_strategies/oplog.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/tap_mongodb/sync_strategies/oplog.py b/tap_mongodb/sync_strategies/oplog.py index 26ef3a5..33def24 100644 --- a/tap_mongodb/sync_strategies/oplog.py +++ b/tap_mongodb/sync_strategies/oplog.py @@ -81,6 +81,7 @@ def transform_projection(projection): # If only '_id' is whitelisted, return base projection with 'o._id' whitelisted new_projection = base_projection new_projection['o._id'] = 1 + new_projection['o.applyOps'] = 1 return new_projection # If whitelist is provided, return base projection along @@ -90,6 +91,7 @@ def transform_projection(projection): for field, value in temp_projection.items(): new_projection['o.' + field] = value new_projection['o._id'] = 1 + new_projection['o.applyOps'] = 1 return new_projection # If blacklist is provided, return blacklisted fields with _id whitelisted