Update airbyte_cdk/sources/declarative/concurrent_declarative_source.py

brianjlai · coderabbitai[bot] · web-flow · commit 05ead347b591 · 2025-01-22T20:24:14.000-05:00
Co-authored-by: coderabbitai[bot] &lt;136622811+coderabbitai[bot]@users.noreply.github.com&gt;
diff --git a/airbyte_cdk/sources/declarative/concurrent_declarative_source.py b/airbyte_cdk/sources/declarative/concurrent_declarative_source.py
@@ -245,7 +245,7 @@ def _group_streams(
                             # This should never happen since we instantiate ConcurrentCursor in
                             # model_to_component_factory.py
                             raise ValueError(
-                                f"Expected AsyncJobPartitionRouter stream_slicer to be of type ConcurrentCursor, but received{cursor.__class__}"
+                                f"Expected AsyncJobPartitionRouter stream_slicer to be of type ConcurrentCursor, but received {cursor.__class__}"
                             )
 
                         partition_generator = StreamSlicerPartitionGenerator(

Original file line number	Diff line number	Diff line change
`@@ -245,7 +245,7 @@ def _group_streams(`
`245`	`245`	`# This should never happen since we instantiate ConcurrentCursor in`
`246`	`246`	`# model_to_component_factory.py`
`247`	`247`	`raise ValueError(`
`248`		`- f"Expected AsyncJobPartitionRouter stream_slicer to be of type ConcurrentCursor, but received{cursor.__class__}"`
	`248`	`+ f"Expected AsyncJobPartitionRouter stream_slicer to be of type ConcurrentCursor, but received {cursor.__class__}"`
`249`	`249`	`)`
`250`	`250`
`251`	`251`	`partition_generator = StreamSlicerPartitionGenerator(`