Remove state delegation retriver import

lazebnyi · lazebnyi · commit 28465227937e · 2025-03-12T04:49:20.000+01:00
diff --git a/airbyte_cdk/sources/declarative/concurrent_declarative_source.py b/airbyte_cdk/sources/declarative/concurrent_declarative_source.py
@@ -222,7 +222,7 @@ def _group_streams(
             ):
                 incremental_sync_component_definition = name_to_stream_mapping[
                     declarative_stream.name
-                ].get("incremental_sync", {})
+                ].get("incremental_sync")
 
                 partition_router_component_definition = (
                     name_to_stream_mapping[declarative_stream.name]
diff --git a/airbyte_cdk/sources/declarative/retrievers/__init__.py b/airbyte_cdk/sources/declarative/retrievers/__init__.py
@@ -8,14 +8,10 @@
     SimpleRetriever,
     SimpleRetrieverTestReadDecorator,
 )
-from airbyte_cdk.sources.declarative.retrievers.state_delegating_retriever import (
-    StateDelegatingRetriever,
-)
 
 __all__ = [
     "Retriever",
     "SimpleRetriever",
     "SimpleRetrieverTestReadDecorator",
     "AsyncRetriever",
-    "StateDelegatingRetriever",
 ]

Original file line number	Diff line number	Diff line change
`@@ -8,14 +8,10 @@`
`8`	`8`	`SimpleRetriever,`
`9`	`9`	`SimpleRetrieverTestReadDecorator,`
`10`	`10`	`)`
`11`		`-from airbyte_cdk.sources.declarative.retrievers.state_delegating_retriever import (`
`12`		`- StateDelegatingRetriever,`
`13`		`-)`
`14`	`11`
`15`	`12`	`__all__ = [`
`16`	`13`	`"Retriever",`
`17`	`14`	`"SimpleRetriever",`
`18`	`15`	`"SimpleRetrieverTestReadDecorator",`
`19`	`16`	`"AsyncRetriever",`
`20`		`- "StateDelegatingRetriever",`
`21`	`17`	`]`