Skip to content

Commit f6c2027

Browse files
authored
feat: adds config_path to source instantiation for sdm, enabling config migrations (#563)
1 parent 3237334 commit f6c2027

File tree

1 file changed

+7
-1
lines changed
  • airbyte_cdk/cli/source_declarative_manifest

1 file changed

+7
-1
lines changed

airbyte_cdk/cli/source_declarative_manifest/_run.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,12 @@ def _get_local_yaml_source(args: list[str]) -> SourceLocalYaml:
9797
try:
9898
parsed_args = AirbyteEntrypoint.parse_args(args)
9999
config, catalog, state = _parse_inputs_into_config_catalog_state(parsed_args)
100-
return SourceLocalYaml(config=config, catalog=catalog, state=state)
100+
return SourceLocalYaml(
101+
config=config,
102+
catalog=catalog,
103+
state=state,
104+
config_path=parsed_args.config if hasattr(parsed_args, "config") else None,
105+
)
101106
except Exception as error:
102107
print(
103108
orjson.dumps(
@@ -206,6 +211,7 @@ def create_declarative_source(
206211
catalog=catalog,
207212
state=state,
208213
source_config=cast(dict[str, Any], config["__injected_declarative_manifest"]),
214+
config_path=parsed_args.config if hasattr(parsed_args, "config") else None,
209215
)
210216
except Exception as error:
211217
print(

0 commit comments

Comments
 (0)