executorlib.standalone.inputcheck

executorlib.standalone.inputcheck#

Functions

check_command_line_argument_lst(...)

Check if command_line_argument_lst is not empty and raise a ValueError if it is.

check_executor(executor)

Check if executor is not None and raise a ValueError if it is.

check_file_exists(file_name)

Check if file exists and raise a ValueError if it does not or file_name is None.

check_flux_log_files(flux_log_files)

Check if flux_log_files is True and raise a ValueError if it is.

check_gpus_per_worker(gpus_per_worker)

Check if gpus_per_worker is not 0 and raise a TypeError if it is.

check_hostname_localhost(hostname_localhost)

Check that hostname_localhost is not set when using a pysqa-based backend.

check_init_function(block_allocation, ...)

Check if block_allocation is False and init_function is not None, and raise a ValueError if it is.

check_log_obj_size(log_obj_size)

Check if log_obj_size is True and raise a ValueError if it is.

check_max_workers_and_cores(max_workers, ...)

Check that neither max_workers nor max_cores is set when using a pysqa-based backend.

check_nested_flux_executor(nested_flux_executor)

Check if nested_flux_executor is True and raise a ValueError if it is.

check_oversubscribe(oversubscribe)

Check if oversubscribe is True and raise a ValueError if it is.

check_plot_dependency_graph(...)

Check if plot_dependency_graph is True and raise a ValueError if it is.

check_pmi(backend, pmi)

Check if pmi is valid for the selected backend and raise a ValueError if it is not.

check_pmi_mode(pmi_mode)

Check that pmi_mode is not set on a local workstation without SLURM or flux.

check_pysqa_config_directory(...)

Check if pysqa_config_directory is None and raise a ValueError if it is not.

check_refresh_rate(refresh_rate)

Check if refresh_rate is not 0.01 and raise a ValueError if it is.

check_resource_dict(function)

Check if the function has a parameter named 'resource_dict' and raise a ValueError if it does.

check_resource_dict_is_empty(resource_dict)

Check if resource_dict is not empty and raise a ValueError if it is.

check_restart_limit(restart_limit[, ...])

Check that restart_limit is only used together with block_allocation.

check_wait_on_shutdown(wait_on_shutdown)

Check if wait_on_shutdown is False and raise a ValueError if it is.

validate_number_of_cores([max_cores, ...])

Validate the number of cores and return the number of workers to use.