From 2673402400a99e30184fdf2dc4a9f7d8f892485b Mon Sep 17 00:00:00 2001
From: Alexandros Milaios <alexmilaios@gmail.com>
Date: Fri, 26 May 2023 11:13:47 +0300
Subject: [PATCH] chore: set lookback window to a constant of  30 mins

---
 .../connectors/source-klaviyo/source_klaviyo/source.py     | 3 +--
 .../connectors/source-klaviyo/source_klaviyo/spec.json     | 7 -------
 .../connectors/source-klaviyo/source_klaviyo/streams.py    | 5 +----
 3 files changed, 2 insertions(+), 13 deletions(-)

diff --git a/airbyte-integrations/connectors/source-klaviyo/source_klaviyo/source.py b/airbyte-integrations/connectors/source-klaviyo/source_klaviyo/source.py
index 96dd228f34524c..fe3d117d3421db 100644
--- a/airbyte-integrations/connectors/source-klaviyo/source_klaviyo/source.py
+++ b/airbyte-integrations/connectors/source-klaviyo/source_klaviyo/source.py
@@ -31,10 +31,9 @@ def streams(self, config: Mapping[str, Any]) -> List[Stream]:
         """
         api_key = config["api_key"]
         start_date = config["start_date"]
-        events_look_back_window = config.get("events_look_back_window", 0)
         return [
             Campaigns(api_key=api_key),
-            Events(api_key=api_key, start_date=start_date, events_look_back_window=events_look_back_window),
+            Events(api_key=api_key, start_date=start_date),
             GlobalExclusions(api_key=api_key, start_date=start_date),
             Lists(api_key=api_key),
             Metrics(api_key=api_key),
diff --git a/airbyte-integrations/connectors/source-klaviyo/source_klaviyo/spec.json b/airbyte-integrations/connectors/source-klaviyo/source_klaviyo/spec.json
index 93b13a07324a3c..8665349ead52cf 100644
--- a/airbyte-integrations/connectors/source-klaviyo/source_klaviyo/spec.json
+++ b/airbyte-integrations/connectors/source-klaviyo/source_klaviyo/spec.json
@@ -19,13 +19,6 @@
         "examples": ["2017-01-25T00:00:00Z"],
         "type": "string",
         "format": "date-time"
-      },
-      "events_look_back_window": {
-        "title": "Events Look Back Window In Minutes",
-        "description": "Events data created in the past N minutes since your last sync ended is re-exported.",
-        "type": "integer",
-        "examples": [10, 20, 30, 60, 120],
-        "default": 0
       }
     },
     "required": ["api_key", "start_date"]
diff --git a/airbyte-integrations/connectors/source-klaviyo/source_klaviyo/streams.py b/airbyte-integrations/connectors/source-klaviyo/source_klaviyo/streams.py
index caaaf21fbbb74b..638ce92ab08010 100644
--- a/airbyte-integrations/connectors/source-klaviyo/source_klaviyo/streams.py
+++ b/airbyte-integrations/connectors/source-klaviyo/source_klaviyo/streams.py
@@ -262,15 +262,12 @@ def path(self, **kwargs) -> str:
 
 class Events(IncrementalKlaviyoStream):
     """Docs: https://developers.klaviyo.com/en/reference/metrics-timeline"""
-    def __init__(self, start_date:str, events_look_back_window: int, **kwargs):
-        super().__init__(start_date=start_date, **kwargs)
-        self.events_look_back_window = events_look_back_window
 
     cursor_field = "timestamp"
 
     @property
     def look_back_window_in_seconds(self) -> Optional[int]:
-        return timedelta(minutes=self.events_look_back_window).seconds
+        return timedelta(minutes=30).seconds
 
     def path(self, **kwargs) -> str:
         return "metrics/timeline"