dlt._workspace.deployment.launchers._launcher

exec_process

def exec_process(argv: List[str]) -> None

View source on GitHub

Replace the current process with argv on POSIX; spawn + wait on Windows.

parse_launcher_args

def parse_launcher_args(
        argv: Optional[List[str]] = None) -> argparse.Namespace

View source on GitHub

Parse the standard launcher command line.

All launchers share the same CLI interface: python -m dlt._workspace.deployment.launchers.<name> --run-id <uuid> --trigger <trigger_string> --entry-point <json_TRuntimeEntryPoint>

get_run_args_port

def get_run_args_port(entry_point: TRuntimeEntryPoint) -> int

View source on GitHub

Extract port from run_args. Raises if not provided.

get_run_args_base_path

def get_run_args_base_path(entry_point: TRuntimeEntryPoint) -> str

View source on GitHub

Extract base_path from run_args. Returns empty string if not set.

resolve_module_path

def resolve_module_path(module_name: str) -> str

View source on GitHub

Resolve a Python module name to its file path.

set_config_env_vars

def set_config_env_vars(sections: Tuple[str, ...], config: Dict[str,
                                                                Any]) -> None

View source on GitHub

Set config params as env vars using EnvironProvider naming convention.