We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent cd55bfd commit 5066ec7Copy full SHA for 5066ec7
1 file changed
unit_tests/sources/declarative/parsers/test_model_to_component_factory.py
@@ -5324,7 +5324,9 @@ def test_block_simultaneous_read_from_stream_groups():
5324
resolved_manifest = resolver.preprocess_manifest(parsed_manifest)
5325
5326
# Build stream_name_to_group from the manifest's stream_groups (as ConcurrentDeclarativeSource does)
5327
- stream_name_to_group = ConcurrentDeclarativeSource._build_stream_name_to_group(resolved_manifest)
+ stream_name_to_group = ConcurrentDeclarativeSource._build_stream_name_to_group(
5328
+ resolved_manifest
5329
+ )
5330
factory_with_groups = ModelToComponentFactory(stream_name_to_group=stream_name_to_group)
5331
5332
# Test parent stream gets block_simultaneous_read from stream_groups
0 commit comments