File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed
airbyte_cdk/sources/declarative Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -206,7 +206,11 @@ def _group_streams(
206206 # these legacy Python streams the way we do low-code streams to determine if they are concurrent compatible,
207207 # so we need to treat them as synchronous
208208
209- if isinstance (declarative_stream , DeclarativeStream ) and name_to_stream_mapping [declarative_stream .name ]["type" ] == "StateDelegatingStream" :
209+ if (
210+ isinstance (declarative_stream , DeclarativeStream )
211+ and name_to_stream_mapping [declarative_stream .name ]["type" ]
212+ == "StateDelegatingStream"
213+ ):
210214 stream_state = self ._connector_state_manager .get_stream_state (
211215 stream_name = declarative_stream .name , namespace = declarative_stream .namespace
212216 )
You can’t perform that action at this time.
0 commit comments