diff --git a/airbyte_cdk/connector_builder/connector_builder_handler.py b/airbyte_cdk/connector_builder/connector_builder_handler.py index 2878a3fda..a7d2163a9 100644 --- a/airbyte_cdk/connector_builder/connector_builder_handler.py +++ b/airbyte_cdk/connector_builder/connector_builder_handler.py @@ -83,6 +83,8 @@ def create_source( state=state, source_config=manifest, emit_connector_builder_messages=True, + migrate_manifest=should_migrate_manifest(config), + normalize_manifest=should_normalize_manifest(config), limits=limits, ) diff --git a/airbyte_cdk/sources/declarative/concurrent_declarative_source.py b/airbyte_cdk/sources/declarative/concurrent_declarative_source.py index 8cdc69a37..8eca7b7dd 100644 --- a/airbyte_cdk/sources/declarative/concurrent_declarative_source.py +++ b/airbyte_cdk/sources/declarative/concurrent_declarative_source.py @@ -95,6 +95,8 @@ def __init__( source_config: ConnectionDefinition, debug: bool = False, emit_connector_builder_messages: bool = False, + migrate_manifest: bool = False, + normalize_manifest: bool = False, limits: Optional[TestLimits] = None, config_path: Optional[str] = None, **kwargs: Any, @@ -135,6 +137,8 @@ def __init__( config=config, debug=debug, emit_connector_builder_messages=emit_connector_builder_messages, + migrate_manifest=migrate_manifest, + normalize_manifest=normalize_manifest, component_factory=component_factory, config_path=config_path, )