def _validate_pull_policy_argument()

in launcher/config_validator/value_validator.py [0:0]

• 7 lines of code
• 3 McCabe index (conditional complexity)

def _validate_pull_policy_argument(config: DictConfig) -> None:
    """
    Check only valid pullPolicy is provided if it is not None

    Parameters:
    config (DictConfig): Configuration dictionary
    """
    pull_policy_argument_name = "cluster.cluster_config.pullPolicy"
    pull_policy_argument = get_argument(config, pull_policy_argument_name)
    if pull_policy_argument is not None:
        supported_pull_policies = ["Always", "IfNotPresent", "Never"]
        if pull_policy_argument not in supported_pull_policies:
            raise ValueError("Provided pullPolicy is not supported")