pass state_migrations when creating concurrent cursor in _group_streams

darynaishchenko · darynaishchenko · commit 8dada3563c5f · 2025-04-28T12:48:24.000+03:00
diff --git a/airbyte_cdk/sources/declarative/concurrent_declarative_source.py b/airbyte_cdk/sources/declarative/concurrent_declarative_source.py
@@ -305,6 +305,7 @@ def _group_streams(
                                 stream_name=declarative_stream.name,
                                 stream_namespace=declarative_stream.namespace,
                                 config=config or {},
+                                stream_state_migrations=declarative_stream.state_migrations,
                             )
                         partition_generator = StreamSlicerPartitionGenerator(
                             partition_factory=DeclarativePartitionFactory(

Original file line number	Diff line number	Diff line change
`@@ -305,6 +305,7 @@ def _group_streams(`
`305`	`305`	`stream_name=declarative_stream.name,`
`306`	`306`	`stream_namespace=declarative_stream.namespace,`
`307`	`307`	`config=config or {},`
	`308`	`+ stream_state_migrations=declarative_stream.state_migrations,`
`308`	`309`	`)`
`309`	`310`	`partition_generator = StreamSlicerPartitionGenerator(`
`310`	`311`	`partition_factory=DeclarativePartitionFactory(`