dlt._workspace.deployment.launchers._launcher
exec_process
def exec_process(argv: List[str]) -> None
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
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
Extract port from run_args. Raises if not provided.
get_run_args_base_path
def get_run_args_base_path(entry_point: TRuntimeEntryPoint) -> str
Extract base_path from run_args. Returns empty string if not set.
resolve_module_path
def resolve_module_path(module_name: str) -> str
Resolve a Python module name to its file path without importing it.
set_config_env_vars
def set_config_env_vars(sections: Tuple[str, ...], config: Dict[str,
Any]) -> None
Set config params as env vars using EnvironProvider naming convention.
apply_job_configuration
def apply_job_configuration(entry_point: TRuntimeEntryPoint) -> None
Updates unset job behavior settings in entry_point from configuration.
Explicit entry point values take precedence over config providers.
prepare_run_env
def prepare_run_env(entry_point: TRuntimeEntryPoint) -> None
Set profile, interval and pipeline refresh env vars, before user code runs.