From 8812763ea26605a3909e544e401cee510d868b00 Mon Sep 17 00:00:00 2001 From: Eugene Kulak Date: Fri, 4 Feb 2022 08:00:26 +0200 Subject: [PATCH] fix after small refactoring --- .../streams/base_insight_streams.py | 10 ++-------- 1 file changed, 2 insertions(+), 8 deletions(-) diff --git a/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/streams/base_insight_streams.py b/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/streams/base_insight_streams.py index a67e0f29344f47..ae688c7370ac8d 100644 --- a/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/streams/base_insight_streams.py +++ b/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/streams/base_insight_streams.py @@ -158,14 +158,8 @@ def _generate_async_jobs(self, params: Mapping) -> Iterator[AsyncJob]: if ts_start in self._completed_slices: continue ts_end = ts_start + pendulum.duration(days=self.time_increment - 1) - total_params = { - **params, - "time_range": { - "since": ts_start.to_date_string(), - "until": ts_end.to_date_string(), - }, - } - yield InsightAsyncJob(self._api.api, edge_object=self._api.account, params=total_params, key=ts_start) + interval = pendulum.Period(ts_start, ts_end.date()) + yield InsightAsyncJob(api=self._api.api, edge_object=self._api.account, interval=interval, params=params) def stream_slices( self, sync_mode: SyncMode, cursor_field: List[str] = None, stream_state: Mapping[str, Any] = None