Skip to content

Commit 2544605

Browse files
committed
fix: resolve breaking change in migration to concurrent declarative as default
1 parent f586d1d commit 2544605

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

airbyte_cdk/connector_builder/connector_builder_handler.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -62,11 +62,13 @@ def should_normalize_manifest(config: Mapping[str, Any]) -> bool:
6262

6363
def create_source(
6464
config: Mapping[str, Any],
65-
limits: TestLimits,
66-
catalog: Optional[ConfiguredAirbyteCatalog],
67-
state: Optional[List[AirbyteStateMessage]],
65+
limits: TestLimits | None = None,
66+
catalog: ConfiguredAirbyteCatalog | None = None,
67+
state: List[AirbyteStateMessage] | None = None,
6868
) -> ConcurrentDeclarativeSource[Optional[List[AirbyteStateMessage]]]:
6969
manifest = config["__injected_declarative_manifest"]
70+
catalog = catalog or None
71+
state = state or None
7072

7173
# We enforce a concurrency level of 1 so that the stream is processed on a single thread
7274
# to retain ordering for the grouping of the builder message responses.

0 commit comments

Comments
 (0)