Merge pull request #61 from michael-mcdonagh/parse-timestamps-in-hook

Parse timestamps in start_fivetran_sync
fivetran · Jun 21, 2022 · b8505e2 · b8505e2
2 parents 10239f5 + 07435bd
commit b8505e2
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/fivetran_provider/hooks/fivetran.py b/fivetran_provider/hooks/fivetran.py
@@ -235,8 +235,11 @@ def start_fivetran_sync(self, connector_id):
         connector_details = self.get_connector(connector_id)
         succeeded_at = connector_details["succeeded_at"]
         failed_at = connector_details["failed_at"]
-        last_sync = succeeded_at if succeeded_at > failed_at else failed_at
-
+        last_sync = (
+            succeeded_at
+            if self._parse_timestamp(succeeded_at) > self._parse_timestamp(failed_at)
+            else failed_at
+        )
         return last_sync
 
     def get_last_sync(self, connector_id, xcom=""):