Merge pull request #20 from menzenski/more-change-stream-fixes

MeltanoLabs · Aug 22, 2023 · 0cb9b47 · 0cb9b47
2 parents 20738c1 + 476fac3
commit 0cb9b47
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pyproject.toml b/pyproject.toml
@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "tap-mongodb"
-version = "2.3.1"
+version = "2.3.2"
 description = "`tap-mongodb` is a Singer tap for MongoDB and AWS DocumentDB, built with the Meltano Singer SDK."
 readme = "README.md"
 authors = ["Matt Menzenski"]

diff --git a/tap_mongodb/streams.py b/tap_mongodb/streams.py
@@ -245,7 +245,7 @@ def get_records(self, context: dict | None) -> Iterable[dict]:
                         ) from operation_failure
                 elif (
                     operation_failure.code == 286
-                    and "as the resume point may no longer be in the oplog." in operation_failure.details["error"]
+                    and "as the resume point may no longer be in the oplog." in operation_failure.details["errmsg"]
                 ):
                     self.logger.warning("Unable to resume change stream from resume token. Resetting resume token.")
                     change_stream_options.pop("resume_after", None)