Ensure stream is declarative

maxi297 · maxi297 · commit bb559b6c5d4c · 2025-03-14T09:33:17.000-04:00
diff --git a/airbyte_cdk/sources/declarative/concurrent_declarative_source.py b/airbyte_cdk/sources/declarative/concurrent_declarative_source.py
@@ -206,7 +206,7 @@ def _group_streams(
             # these legacy Python streams the way we do low-code streams to determine if they are concurrent compatible,
             # so we need to treat them as synchronous
 
-            if name_to_stream_mapping[declarative_stream.name]["type"] == "StateDelegatingStream":
+            if isinstance(declarative_stream, DeclarativeStream) and name_to_stream_mapping[declarative_stream.name]["type"] == "StateDelegatingStream":
                 stream_state = self._connector_state_manager.get_stream_state(
                     stream_name=declarative_stream.name, namespace=declarative_stream.namespace
                 )

Original file line number	Diff line number	Diff line change
`@@ -206,7 +206,7 @@ def _group_streams(`
`206`	`206`	`# these legacy Python streams the way we do low-code streams to determine if they are concurrent compatible,`
`207`	`207`	`# so we need to treat them as synchronous`
`208`	`208`
`209`		`- if name_to_stream_mapping[declarative_stream.name]["type"] == "StateDelegatingStream":`
	`209`	`+ if isinstance(declarative_stream, DeclarativeStream) and name_to_stream_mapping[declarative_stream.name]["type"] == "StateDelegatingStream":`
`210`	`210`	`stream_state = self._connector_state_manager.get_stream_state(`
`211`	`211`	`stream_name=declarative_stream.name, namespace=declarative_stream.namespace`
`212`	`212`	`)`