[ISSUE #15628] update release information and clean return statement

airbytehq · Dec 8, 2022 · 51d612d · 51d612d
1 parent 80b2918
commit 51d612d
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/airbyte-cdk/python/CHANGELOG.md b/airbyte-cdk/python/CHANGELOG.md
@@ -1,5 +1,8 @@
 # Changelog
 
+## 0.12.4
+Lookback window should applied when a state is supplied as well
+
 ## 0.12.3
 Low-code: Finally, make `OffsetIncrement.page_size` interpolated string or int
 

diff --git a/airbyte-cdk/python/airbyte_cdk/sources/declarative/stream_slicers/datetime_stream_slicer.py b/airbyte-cdk/python/airbyte_cdk/sources/declarative/stream_slicers/datetime_stream_slicer.py
@@ -150,8 +150,7 @@ def stream_slices(self, sync_mode: SyncMode, stream_state: Mapping[str, Any]) ->
         cursor_datetime = self._calculate_cursor_datetime_from_state(stream_state)
         start_datetime = max(earliest_possible_start_datetime, cursor_datetime) - lookback_delta
 
-        dates = self._partition_daterange(start_datetime, end_datetime, self._step)
-        return dates
+        return self._partition_daterange(start_datetime, end_datetime, self._step)
 
     def _calculate_cursor_datetime_from_state(self, stream_state: Mapping[str, Any]) -> datetime.datetime:
         if self.cursor_field.eval(self.config, stream_state=stream_state) in stream_state:

diff --git a/airbyte-cdk/python/setup.py b/airbyte-cdk/python/setup.py
@@ -15,7 +15,7 @@
 
 setup(
     name="airbyte-cdk",
-    version="0.12.3",
+    version="0.12.4",
     description="A framework for writing Airbyte Connectors.",
     long_description=README,
     long_description_content_type="text/markdown",