diff --git a/airbyte-integrations/connectors/source-klaviyo/source_klaviyo/source.py b/airbyte-integrations/connectors/source-klaviyo/source_klaviyo/source.py index 96dd228f34524..fe3d117d3421d 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 93b13a07324a3..8665349ead52c 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 caaaf21fbbb74..638ce92ab0801 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"