diff --git a/airbyte/_executors/declarative.py b/airbyte/_executors/declarative.py index e227eca34..e71b85ace 100644 --- a/airbyte/_executors/declarative.py +++ b/airbyte/_executors/declarative.py @@ -45,6 +45,7 @@ def __init__( self, name: str, manifest: dict | Path, + config: dict[str, Any] = {}, components_py: str | Path | None = None, components_py_checksum: str | None = None, ) -> None: @@ -66,7 +67,7 @@ def __init__( elif isinstance(manifest, dict): self._manifest_dict = manifest - config_dict: dict[str, Any] = {} + config_dict: dict[str, Any] = config if components_py: if isinstance(components_py, Path): components_py = components_py.read_text() diff --git a/airbyte/_executors/util.py b/airbyte/_executors/util.py index ca4dd7d2f..ca2d729ea 100644 --- a/airbyte/_executors/util.py +++ b/airbyte/_executors/util.py @@ -169,6 +169,7 @@ def get_connector_executor( # noqa: PLR0912, PLR0913, PLR0914, PLR0915, C901 # install_root: Path | None = None, use_python: bool | Path | str | None = None, no_executor: bool = False, + config: dict[str, Any] = {} ) -> Executor: """This factory function creates an executor for a connector. @@ -334,6 +335,7 @@ def get_connector_executor( # noqa: PLR0912, PLR0913, PLR0914, PLR0915, C901 # return DeclarativeExecutor( name=name, manifest=source_manifest, + config=config, components_py=components_py_path, ) @@ -349,6 +351,7 @@ def get_connector_executor( # noqa: PLR0912, PLR0913, PLR0914, PLR0915, C901 # return DeclarativeExecutor( name=name, manifest=manifest_dict, + config=config, components_py=components_py, components_py_checksum=components_py_checksum, ) diff --git a/airbyte/sources/util.py b/airbyte/sources/util.py index 42372ed03..96f2cbd11 100644 --- a/airbyte/sources/util.py +++ b/airbyte/sources/util.py @@ -128,6 +128,7 @@ def get_source( # noqa: PLR0913 # Too many arguments install_if_missing=install_if_missing, install_root=install_root, no_executor=no_executor, + config=config, ) return Source(