Fix mypy

lazebnyi · lazebnyi · commit c757bbd65dda · 2025-03-22T01:33:58.000+01:00
diff --git a/airbyte_cdk/sources/declarative/manifest_declarative_source.py b/airbyte_cdk/sources/declarative/manifest_declarative_source.py
@@ -106,7 +106,7 @@ def __init__(
             AlwaysLogSliceLogger() if emit_connector_builder_messages else DebugSliceLogger()
         )
 
-        self._config = config
+        self._config = config or {}
         self._validate_source()
 
     @property
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,6 @@ def test_group_streams():
     )
     concurrent_streams, synchronous_streams = source._group_streams(config=_CONFIG)
 
-    for stream in source._stream_configs(source.resolved_manifest):
-        assert stream["dynamic_stream_name"] is None
-
     # 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) == 8

Original file line number	Diff line number	Diff line change
`@@ -106,7 +106,7 @@ def __init__(`
`106`	`106`	`AlwaysLogSliceLogger() if emit_connector_builder_messages else DebugSliceLogger()`
`107`	`107`	`)`
`108`	`108`
`109`		`- self._config = config`
	`109`	`+ self._config = config or {}`
`110`	`110`	`self._validate_source()`
`111`	`111`
`112`	`112`	`@property`
Original file line number	Diff line number	Diff line change
`@@ -709,9 +709,6 @@ def test_group_streams():`
`709`	`709`	`)`
`710`	`710`	`concurrent_streams, synchronous_streams = source._group_streams(config=_CONFIG)`
`711`	`711`
`712`		`- for stream in source._stream_configs(source.resolved_manifest):`
`713`		`- assert stream["dynamic_stream_name"] is None`
`714`		`-`
`715`	`712`	`# 1 full refresh stream, 3 incremental streams, 1 substream w/o incremental, 1 list based substream w/o incremental`
`716`	`713`	`# 1 async job stream, 1 substream w/ incremental`
`717`	`714`	`assert len(concurrent_streams) == 8`