backends.utils#
Module Contents#
Functions#
Recursively merge two executor configs with deep merging of nested dicts. |
|
Initialize a new local Ray cluster or connects to an existing one. |
|
API#
- backends.utils.merge_executor_configs(
- base_config: dict | None,
- override_config: dict | None,
Recursively merge two executor configs with deep merging of nested dicts.
Args: base_config: Base configuration dictionary override_config: Configuration to merge on top of base_config
Returns: Merged configuration dictionary with all nested dicts recursively merged
Notes: - Recursively merges all nested dictionaries - Non-dict values in override_config will overwrite base_config - Handles None values gracefully - Does not modify original inputs (uses deep copy)
Examples: >>> base = {“runtime_env”: {“env_vars”: {“A”: “1”, “B”: “2”}}} >>> override = {“runtime_env”: {“env_vars”: {“B”: “3”, “C”: “4”}}} >>> merge_executor_configs(base, override) {“runtime_env”: {“env_vars”: {“A”: “1”, “B”: “3”, “C”: “4”}}}
- backends.utils.register_loguru_serializer() None#
Initialize a new local Ray cluster or connects to an existing one.
- backends.utils.warn_on_env_var_override(
- existing_config: dict | None,
- merged_config: dict | None,