CDK: fix test

artem1205 · artem1205 · commit 075ac16fcfd9 · 2025-02-27T19:13:46.000+01:00
Signed-off-by: Artem Inzhyyants &lt;artem.inzhyyants@gmail.com&gt;
diff --git a/unit_tests/sources/declarative/test_concurrent_declarative_source.py b/unit_tests/sources/declarative/test_concurrent_declarative_source.py
@@ -709,9 +709,9 @@ def test_group_streams():
     )
     concurrent_streams, synchronous_streams = source._group_streams(config=_CONFIG)
 
-    # 1 full refresh stream, 2 incremental streams, 1 substream w/o incremental, 1 list based substream w/o incremental
+    # 1 full refresh stream, 3 incremental streams, 1 substream w/o incremental, 1 list based substream w/o incremental
     # 1 async job stream, 1 substream w/ incremental
-    assert len(concurrent_streams) == 7
+    assert len(concurrent_streams) == 8
     (
         concurrent_stream_0,
         concurrent_stream_1,

Original file line number	Diff line number	Diff line change
`@@ -709,9 +709,9 @@ def test_group_streams():`
`709`	`709`	`)`
`710`	`710`	`concurrent_streams, synchronous_streams = source._group_streams(config=_CONFIG)`
`711`	`711`
`712`		`- # 1 full refresh stream, 2 incremental streams, 1 substream w/o incremental, 1 list based substream w/o incremental`
	`712`	`+ # 1 full refresh stream, 3 incremental streams, 1 substream w/o incremental, 1 list based substream w/o incremental`
`713`	`713`	`# 1 async job stream, 1 substream w/ incremental`
`714`		`- assert len(concurrent_streams) == 7`
	`714`	`+ assert len(concurrent_streams) == 8`
`715`	`715`	`(`
`716`	`716`	`concurrent_stream_0,`
`717`	`717`	`concurrent_stream_1,`