Fix

meltano · Sep 26, 2024 · 4aebb00 · 4aebb00
1 parent a2ab8b1
commit 4aebb00
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 6 deletions.
diff --git a/tap_iceberg/streams.py b/tap_iceberg/streams.py
@@ -60,11 +60,6 @@ def get_records(self, context: dict | None = None) -> Iterable[dict]:
                 self.replication_key,
                 start_value,
             )
-            # Convert to timezone-less isoformat string.
-            if isinstance(start_value, str):
-                start_value = (
-                    datetime.fromisoformat(start_value).replace(tzinfo=None).isoformat()
-                )
             filter_expression = GreaterThan(self.replication_key, start_value)
         batch_reader = self._iceberg_table.scan(
             row_filter=filter_expression,

diff --git a/tests/test_core.py b/tests/test_core.py
@@ -29,7 +29,7 @@
         "bookmarks": {
             "test_namespace-test_table": {
                 "replication_key": "updated_at",
-                "replication_key_value": "2024-07-23T00:00:00.000000+00:00",
+                "replication_key_value": "2024-07-23T00:00:00.000000",
             }
         }
     },