feat: Use sorted API requests to support crash tolerant incremental s…

…ync (#32)

The streams changed support sorted responses

Ex: https://developers.klaviyo.com/en/reference/get_campaigns

This PR takes advantage of ascending timestamps to support fault
tolerant incremental syncs that picks up at the last left-off place.

tap_klaviyo/client.py

@@ -96,6 +96,9 @@ def get_url_params(
             else:
                 filter_timestamp = DEFAULT_START_DATE
 
+            if self.is_sorted:
+                params["sort"] = self.replication_key
+
             params["filter"] = f"greater-than({self.replication_key},{filter_timestamp})"
 
         return params

tap_klaviyo/streams.py

@@ -30,6 +30,10 @@ def post_process(
         row["datetime"] = row["attributes"]["datetime"]
         return row
 
+    @property
+    def is_sorted(self) -> bool:
+        return True
+
 
 class CampaignsStream(KlaviyoStream):
     """Define custom stream."""
@@ -73,6 +77,10 @@ def post_process(
         row["updated_at"] = row["attributes"]["updated_at"]
         return row
 
+    @property
+    def is_sorted(self) -> bool:
+        return True
+
 
 class ProfilesStream(KlaviyoStream):
     """Define custom stream."""
@@ -91,6 +99,10 @@ def post_process(
         row["updated"] = row["attributes"]["updated"]
         return row
 
+    @property
+    def is_sorted(self) -> bool:
+        return True
+
 
 class MetricsStream(KlaviyoStream):
     """Define custom stream."""
@@ -175,3 +187,7 @@ def post_process(
     ) -> dict | None:
         row["updated"] = row["attributes"]["updated"]
         return row
+
+    @property
+    def is_sorted(self) -> bool:
+        return True