Merge branch 'lazebnyi/add-state-delegating-retriever' of github.com:…

…airbytehq/airbyte-python-cdk into lazebnyi/add-state-delegating-retriever
airbytehq · Feb 12, 2025 · 407766d · 407766d
2 parents 8cbb9b2 + 1a4b044
commit 407766d
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py b/airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py
@@ -1826,7 +1826,7 @@ def _validate_retriever(self, model: DeclarativeStreamModel) -> None:
                 raise ValueError("Per partition state is not supported yet for AsyncRetriever.")
 
     def _merge_stream_slicers(
-            self, model: DeclarativeStreamModel, config: Config
+        self, model: DeclarativeStreamModel, config: Config
     ) -> Optional[StreamSlicer]:
         self._validate_retriever(model)
 
@@ -1835,8 +1835,11 @@ def _merge_stream_slicers(
         if model.incremental_sync:
             return self._build_incremental_cursor(model, stream_slicer, config)
 
-        return stream_slicer if self._disable_resumable_full_refresh else self._build_resumable_cursor(model.retriever,
-                                                                                                       stream_slicer)
+        return (
+            stream_slicer
+            if self._disable_resumable_full_refresh
+            else self._build_resumable_cursor(model.retriever, stream_slicer)
+        )
 
     def create_default_error_handler(
             self, model: DefaultErrorHandlerModel, config: Config, **kwargs: Any