Update core.py

ericboucher · Jun 28, 2022 · 8dc6cad · 8dc6cad
1 parent fe6a2f7
commit 8dc6cad
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/singer_sdk/streams/core.py b/singer_sdk/streams/core.py
@@ -326,8 +326,10 @@ def _write_starting_replication_value(self, context: Optional[dict]) -> None:
                 if not value:
                     value = self.config["start_date"]
                 else:
-                    value_datetime: DateTime = pendulum.parse(value)
-                    start_datetime: DateTime = pendulum.parse(self.config["start_date"])
+                    value_datetime = cast(datetime.datetime, pendulum.parse(value))
+                    start_datetime = cast(
+                        datetime.datetime, pendulum.parse(self.config["start_date"])
+                    )
                     value = (
                         value
                         if value_datetime > start_datetime