diff --git a/pyproject.toml b/pyproject.toml index 315e1bb..10b3c7a 100644 --- 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 index acab9db..e72c317 100644 --- 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)