Index

_

__init__() (executorlib.executor.base.BaseExecutor method) (executorlib.executor.flux.FluxClusterExecutor method) (executorlib.executor.flux.FluxJobExecutor method) (executorlib.executor.single.SingleNodeExecutor method) (executorlib.executor.single.TestClusterExecutor method) (executorlib.executor.slurm.SlurmClusterExecutor method) (executorlib.executor.slurm.SlurmJobExecutor method) (executorlib.standalone.interactive.communication.SocketInterface method) (executorlib.standalone.interactive.spawner.BaseSpawner method) (executorlib.standalone.interactive.spawner.MpiExecSpawner method) (executorlib.standalone.interactive.spawner.SubprocessSpawner method) (executorlib.standalone.select.FutureSelector method) (executorlib.standalone.validate.ResourceDictValidation method) (executorlib.task_scheduler.base.TaskSchedulerBase method) (executorlib.task_scheduler.file.shared.FutureItem method) (executorlib.task_scheduler.file.task_scheduler.FileTaskScheduler method) (executorlib.task_scheduler.interactive.blockallocation.BlockAllocationTaskScheduler method) (executorlib.task_scheduler.interactive.dependency.DependencyTaskScheduler method) (executorlib.task_scheduler.interactive.onetoone.OneProcessTaskScheduler method) (executorlib.task_scheduler.interactive.spawner_flux.FluxPythonSpawner method) (executorlib.task_scheduler.interactive.spawner_slurm.SrunSpawner method)

_future_hash_dict (executorlib.task_scheduler.interactive.dependency.DependencyTaskScheduler attribute) _generate_dependency_graph (executorlib.task_scheduler.interactive.dependency.DependencyTaskScheduler attribute), [1] _task_hash_dict (executorlib.task_scheduler.interactive.dependency.DependencyTaskScheduler attribute)

A

add_done_callback() (executorlib.standalone.select.FutureSelector method)

B

backend_execute_task_in_file() (in module executorlib.task_scheduler.file.backend) backend_load_file() (in module executorlib.task_scheduler.file.backend) backend_write_error_file() (in module executorlib.standalone.error) backend_write_file() (in module executorlib.task_scheduler.file.backend) BaseExecutor (class in executorlib.executor.base) BaseSpawner (class in executorlib.standalone.interactive.spawner) batched() (executorlib.executor.base.BaseExecutor method) (executorlib.executor.flux.FluxClusterExecutor method) (executorlib.executor.flux.FluxJobExecutor method) (executorlib.executor.single.SingleNodeExecutor method) (executorlib.executor.single.TestClusterExecutor method) (executorlib.executor.slurm.SlurmClusterExecutor method) (executorlib.executor.slurm.SlurmJobExecutor method) (executorlib.task_scheduler.base.TaskSchedulerBase method) (executorlib.task_scheduler.file.task_scheduler.FileTaskScheduler method) (executorlib.task_scheduler.interactive.blockallocation.BlockAllocationTaskScheduler method) (executorlib.task_scheduler.interactive.dependency.DependencyTaskScheduler method) (executorlib.task_scheduler.interactive.onetoone.OneProcessTaskScheduler method)

batched_futures() (in module executorlib.standalone.batched) bind_to_random_port() (executorlib.standalone.interactive.communication.SocketInterface method) BlockAllocationTaskScheduler (class in executorlib.task_scheduler.interactive.blockallocation) bootup() (executorlib.standalone.interactive.communication.SocketInterface method) (executorlib.standalone.interactive.spawner.BaseSpawner method) (executorlib.standalone.interactive.spawner.MpiExecSpawner method) (executorlib.standalone.interactive.spawner.SubprocessSpawner method) (executorlib.task_scheduler.interactive.spawner_flux.FluxPythonSpawner method) (executorlib.task_scheduler.interactive.spawner_slurm.SrunSpawner method)

C

cache_directory (executorlib.standalone.validate.ResourceDictValidation attribute) cache_key (executorlib.standalone.validate.ResourceDictValidation attribute) call_funct() (in module executorlib.standalone.interactive.backend) cancel() (executorlib.standalone.select.FutureSelector method) cancel_items_in_queue() (in module executorlib.standalone.queue) cancelled() (executorlib.standalone.select.FutureSelector method) check_command_line_argument_lst() (in module executorlib.standalone.inputcheck) check_exception_was_raised() (in module executorlib.standalone.interactive.arguments) check_executor() (in module executorlib.standalone.inputcheck) check_file_exists() (in module executorlib.standalone.inputcheck) check_flux_log_files() (in module executorlib.standalone.inputcheck) check_gpus_per_worker() (in module executorlib.standalone.inputcheck) check_hostname_localhost() (in module executorlib.standalone.inputcheck) check_init_function() (in module executorlib.standalone.inputcheck) check_list_of_futures_is_done() (in module executorlib.standalone.interactive.arguments) check_log_obj_size() (in module executorlib.standalone.inputcheck) check_max_workers_and_cores() (in module executorlib.standalone.inputcheck) check_nested_flux_executor() (in module executorlib.standalone.inputcheck)

check_oversubscribe() (in module executorlib.standalone.inputcheck) check_plot_dependency_graph() (in module executorlib.standalone.inputcheck) check_pmi() (in module executorlib.standalone.inputcheck) check_pmi_mode() (in module executorlib.standalone.inputcheck) check_pysqa_config_directory() (in module executorlib.standalone.inputcheck) check_refresh_rate() (in module executorlib.standalone.inputcheck) check_resource_dict() (in module executorlib.standalone.inputcheck) check_resource_dict_is_empty() (in module executorlib.standalone.inputcheck) check_restart_limit() (in module executorlib.standalone.inputcheck) check_wait_on_shutdown() (in module executorlib.standalone.inputcheck) cloudpickle_register() (in module executorlib.standalone.serialize) copy() (executorlib.standalone.validate.ResourceDictValidation method) cores (executorlib.standalone.validate.ResourceDictValidation attribute) create_file_executor() (in module executorlib.task_scheduler.file.task_scheduler) create_flux_executor() (in module executorlib.executor.flux) create_single_node_executor() (in module executorlib.executor.single) create_slurm_executor() (in module executorlib.executor.slurm) cwd (executorlib.standalone.validate.ResourceDictValidation attribute)

D

DependencyTaskScheduler (class in executorlib.task_scheduler.interactive.dependency) done() (executorlib.standalone.select.FutureSelector method) (executorlib.task_scheduler.file.shared.FutureItem method)

dump() (in module executorlib.standalone.hdf)

E

error_log_file (executorlib.standalone.validate.ResourceDictValidation attribute) exception() (executorlib.standalone.select.FutureSelector method) exclusive (executorlib.standalone.validate.ResourceDictValidation attribute) execute_in_subprocess() (in module executorlib.task_scheduler.file.spawner_subprocess) execute_task_dict() (in module executorlib.task_scheduler.interactive.shared) execute_tasks_h5() (in module executorlib.task_scheduler.file.shared) executorlib module executorlib.api module executorlib.backend module executorlib.backend.cache_parallel module executorlib.backend.cache_serial module executorlib.backend.interactive_parallel module executorlib.backend.interactive_serial module executorlib.executor module executorlib.executor.base module executorlib.executor.flux module executorlib.executor.single module executorlib.executor.slurm module executorlib.standalone module executorlib.standalone.batched module executorlib.standalone.command module executorlib.standalone.error module executorlib.standalone.hdf module executorlib.standalone.inputcheck module executorlib.standalone.interactive module executorlib.standalone.interactive.arguments module

executorlib.standalone.interactive.backend module executorlib.standalone.interactive.communication module executorlib.standalone.interactive.spawner module executorlib.standalone.queue module executorlib.standalone.select module executorlib.standalone.serialize module executorlib.standalone.validate module executorlib.task_scheduler module executorlib.task_scheduler.base module executorlib.task_scheduler.file module executorlib.task_scheduler.file.backend module executorlib.task_scheduler.file.shared module executorlib.task_scheduler.file.spawner_subprocess module executorlib.task_scheduler.file.task_scheduler module executorlib.task_scheduler.interactive module executorlib.task_scheduler.interactive.blockallocation module executorlib.task_scheduler.interactive.dependency module executorlib.task_scheduler.interactive.dependency_plot module executorlib.task_scheduler.interactive.onetoone module executorlib.task_scheduler.interactive.shared module executorlib.task_scheduler.interactive.spawner_flux module executorlib.task_scheduler.interactive.spawner_slurm module ExecutorlibSocketError export_dependency_graph_function() (in module executorlib.task_scheduler.interactive.dependency_plot)

F

FileTaskScheduler (class in executorlib.task_scheduler.file.task_scheduler) FluxClusterExecutor (class in executorlib.executor.flux) FluxJobExecutor (class in executorlib.executor.flux) FluxPythonSpawner (class in executorlib.task_scheduler.interactive.spawner_flux) future_queue (executorlib.executor.base.BaseExecutor property) (executorlib.executor.flux.FluxClusterExecutor property) (executorlib.executor.flux.FluxJobExecutor property) (executorlib.executor.single.SingleNodeExecutor property) (executorlib.executor.single.TestClusterExecutor property) (executorlib.executor.slurm.SlurmClusterExecutor property) (executorlib.executor.slurm.SlurmJobExecutor property) (executorlib.task_scheduler.base.TaskSchedulerBase property) (executorlib.task_scheduler.file.task_scheduler.FileTaskScheduler property) (executorlib.task_scheduler.interactive.blockallocation.BlockAllocationTaskScheduler property) (executorlib.task_scheduler.interactive.dependency.DependencyTaskScheduler property) (executorlib.task_scheduler.interactive.onetoone.OneProcessTaskScheduler property)

FutureItem (class in executorlib.task_scheduler.file.shared) FutureSelector (class in executorlib.standalone.select)

G

generate_command() (executorlib.standalone.interactive.spawner.MpiExecSpawner method) (executorlib.standalone.interactive.spawner.SubprocessSpawner method) (executorlib.task_scheduler.interactive.spawner_slurm.SrunSpawner method) generate_mpiexec_command() (in module executorlib.standalone.interactive.spawner) generate_nodes_and_edges_for_plotting() (in module executorlib.task_scheduler.interactive.dependency_plot) generate_slurm_command() (in module executorlib.standalone.command) generate_task_hash_for_plotting() (in module executorlib.task_scheduler.interactive.dependency_plot) get_cache_data() (in module executorlib) (in module executorlib.standalone.hdf) get_cache_execute_command() (in module executorlib.standalone.command) get_cache_files() (in module executorlib.standalone.hdf)

get_command_path() (in module executorlib.standalone.command) get_exception_lst() (in module executorlib.standalone.interactive.arguments) get_future_from_cache() (in module executorlib) (in module executorlib.standalone.hdf) get_future_objects_from_input() (in module executorlib.standalone.interactive.arguments) get_interactive_execute_command() (in module executorlib.standalone.command) get_item_from_future() (in module executorlib.standalone.select) get_output() (in module executorlib.standalone.hdf) get_queue_id() (in module executorlib.standalone.hdf) get_runtime() (in module executorlib.standalone.hdf) gpus_per_core (executorlib.standalone.validate.ResourceDictValidation attribute)

I

info (executorlib.executor.base.BaseExecutor property) (executorlib.executor.flux.FluxClusterExecutor property) (executorlib.executor.flux.FluxJobExecutor property) (executorlib.executor.single.SingleNodeExecutor property) (executorlib.executor.single.TestClusterExecutor property) (executorlib.executor.slurm.SlurmClusterExecutor property) (executorlib.executor.slurm.SlurmJobExecutor property) (executorlib.task_scheduler.base.TaskSchedulerBase property) (executorlib.task_scheduler.file.task_scheduler.FileTaskScheduler property) (executorlib.task_scheduler.interactive.blockallocation.BlockAllocationTaskScheduler property) (executorlib.task_scheduler.interactive.dependency.DependencyTaskScheduler property) (executorlib.task_scheduler.interactive.onetoone.OneProcessTaskScheduler property)

interface_bootup() (in module executorlib.standalone.interactive.communication) interface_connect() (in module executorlib.standalone.interactive.communication) interface_receive() (in module executorlib.standalone.interactive.communication) interface_send() (in module executorlib.standalone.interactive.communication) interface_shutdown() (in module executorlib.standalone.interactive.communication)

L

load() (in module executorlib.standalone.hdf)

M

main() (in module executorlib.backend.cache_parallel) (in module executorlib.backend.interactive_parallel) (in module executorlib.backend.interactive_serial) map() (executorlib.executor.base.BaseExecutor method) (executorlib.executor.flux.FluxClusterExecutor method) (executorlib.executor.flux.FluxJobExecutor method) (executorlib.executor.single.SingleNodeExecutor method) (executorlib.executor.single.TestClusterExecutor method) (executorlib.executor.slurm.SlurmClusterExecutor method) (executorlib.executor.slurm.SlurmJobExecutor method) (executorlib.task_scheduler.base.TaskSchedulerBase method) (executorlib.task_scheduler.file.task_scheduler.FileTaskScheduler method) (executorlib.task_scheduler.interactive.blockallocation.BlockAllocationTaskScheduler method) (executorlib.task_scheduler.interactive.dependency.DependencyTaskScheduler method) (executorlib.task_scheduler.interactive.onetoone.OneProcessTaskScheduler method) max_workers (executorlib.executor.base.BaseExecutor property) (executorlib.executor.flux.FluxClusterExecutor property) (executorlib.executor.flux.FluxJobExecutor property) (executorlib.executor.single.SingleNodeExecutor property) (executorlib.executor.single.TestClusterExecutor property) (executorlib.executor.slurm.SlurmClusterExecutor property) (executorlib.executor.slurm.SlurmJobExecutor property) (executorlib.task_scheduler.base.TaskSchedulerBase property) (executorlib.task_scheduler.file.task_scheduler.FileTaskScheduler property) (executorlib.task_scheduler.interactive.blockallocation.BlockAllocationTaskScheduler property) (executorlib.task_scheduler.interactive.dependency.DependencyTaskScheduler property) (executorlib.task_scheduler.interactive.onetoone.OneProcessTaskScheduler property) model_config (executorlib.standalone.validate.ResourceDictValidation attribute) model_construct() (executorlib.standalone.validate.ResourceDictValidation class method) model_copy() (executorlib.standalone.validate.ResourceDictValidation method) model_dump() (executorlib.standalone.validate.ResourceDictValidation method) model_dump_json() (executorlib.standalone.validate.ResourceDictValidation method) model_extra (executorlib.standalone.validate.ResourceDictValidation property) model_fields_set (executorlib.standalone.validate.ResourceDictValidation property) model_json_schema() (executorlib.standalone.validate.ResourceDictValidation class method) model_parametrized_name() (executorlib.standalone.validate.ResourceDictValidation class method) model_post_init() (executorlib.standalone.validate.ResourceDictValidation method) model_rebuild() (executorlib.standalone.validate.ResourceDictValidation class method) model_validate() (executorlib.standalone.validate.ResourceDictValidation class method) model_validate_json() (executorlib.standalone.validate.ResourceDictValidation class method) model_validate_strings() (executorlib.standalone.validate.ResourceDictValidation class method) module executorlib executorlib.api executorlib.backend executorlib.backend.cache_parallel executorlib.backend.cache_serial executorlib.backend.interactive_parallel executorlib.backend.interactive_serial executorlib.executor executorlib.executor.base executorlib.executor.flux executorlib.executor.single executorlib.executor.slurm executorlib.standalone executorlib.standalone.batched executorlib.standalone.command executorlib.standalone.error executorlib.standalone.hdf executorlib.standalone.inputcheck executorlib.standalone.interactive executorlib.standalone.interactive.arguments executorlib.standalone.interactive.backend executorlib.standalone.interactive.communication executorlib.standalone.interactive.spawner executorlib.standalone.queue executorlib.standalone.select executorlib.standalone.serialize executorlib.standalone.validate executorlib.task_scheduler executorlib.task_scheduler.base executorlib.task_scheduler.file executorlib.task_scheduler.file.backend executorlib.task_scheduler.file.shared executorlib.task_scheduler.file.spawner_subprocess executorlib.task_scheduler.file.task_scheduler executorlib.task_scheduler.interactive executorlib.task_scheduler.interactive.blockallocation executorlib.task_scheduler.interactive.dependency executorlib.task_scheduler.interactive.dependency_plot executorlib.task_scheduler.interactive.onetoone executorlib.task_scheduler.interactive.shared executorlib.task_scheduler.interactive.spawner_flux executorlib.task_scheduler.interactive.spawner_slurm

MpiExecSpawner (class in executorlib.standalone.interactive.spawner)

N

num_nodes (executorlib.standalone.validate.ResourceDictValidation attribute)

O

OneProcessTaskScheduler (class in executorlib.task_scheduler.interactive.onetoone)

P

parse_arguments() (in module executorlib.standalone.interactive.backend) plot_dependency_graph_function() (in module executorlib.task_scheduler.interactive.dependency_plot) poll() (executorlib.standalone.interactive.spawner.BaseSpawner method) (executorlib.standalone.interactive.spawner.MpiExecSpawner method) (executorlib.standalone.interactive.spawner.SubprocessSpawner method) (executorlib.task_scheduler.interactive.spawner_flux.FluxPythonSpawner method) (executorlib.task_scheduler.interactive.spawner_slurm.SrunSpawner method)

priority (executorlib.standalone.validate.ResourceDictValidation attribute)

R

receive_dict() (executorlib.standalone.interactive.communication.SocketInterface method) reset_task_dict() (in module executorlib.task_scheduler.interactive.shared) ResourceDictValidation (class in executorlib.standalone.validate)

result() (executorlib.standalone.select.FutureSelector method) (executorlib.task_scheduler.file.shared.FutureItem method) run_time_max (executorlib.standalone.validate.ResourceDictValidation attribute) running() (executorlib.standalone.select.FutureSelector method)

S

send_and_receive_dict() (executorlib.standalone.interactive.communication.SocketInterface method) send_dict() (executorlib.standalone.interactive.communication.SocketInterface method) serialize_funct() (in module executorlib.standalone.serialize) set_current_directory_in_environment() (in module executorlib.standalone.interactive.spawner) set_exception() (executorlib.standalone.select.FutureSelector method) set_result() (executorlib.standalone.select.FutureSelector method) set_running_or_notify_cancel() (executorlib.standalone.select.FutureSelector method) shutdown() (executorlib.executor.base.BaseExecutor method) (executorlib.executor.flux.FluxClusterExecutor method) (executorlib.executor.flux.FluxJobExecutor method) (executorlib.executor.single.SingleNodeExecutor method) (executorlib.executor.single.TestClusterExecutor method) (executorlib.executor.slurm.SlurmClusterExecutor method) (executorlib.executor.slurm.SlurmJobExecutor method) (executorlib.standalone.interactive.communication.SocketInterface method) (executorlib.standalone.interactive.spawner.BaseSpawner method) (executorlib.standalone.interactive.spawner.MpiExecSpawner method) (executorlib.standalone.interactive.spawner.SubprocessSpawner method) (executorlib.task_scheduler.base.TaskSchedulerBase method) (executorlib.task_scheduler.file.task_scheduler.FileTaskScheduler method) (executorlib.task_scheduler.interactive.blockallocation.BlockAllocationTaskScheduler method) (executorlib.task_scheduler.interactive.dependency.DependencyTaskScheduler method) (executorlib.task_scheduler.interactive.onetoone.OneProcessTaskScheduler method) (executorlib.task_scheduler.interactive.spawner_flux.FluxPythonSpawner method) (executorlib.task_scheduler.interactive.spawner_slurm.SrunSpawner method)

SingleNodeExecutor (class in executorlib.executor.single) slurm_cmd_args (executorlib.standalone.validate.ResourceDictValidation attribute) SlurmClusterExecutor (class in executorlib.executor.slurm) SlurmJobExecutor (class in executorlib.executor.slurm) SocketInterface (class in executorlib.standalone.interactive.communication) split_future() (in module executorlib.standalone.select) SrunSpawner (class in executorlib.task_scheduler.interactive.spawner_slurm) submission_template (executorlib.standalone.validate.ResourceDictValidation attribute) submit() (executorlib.executor.base.BaseExecutor method) (executorlib.executor.flux.FluxClusterExecutor method) (executorlib.executor.flux.FluxJobExecutor method) (executorlib.executor.single.SingleNodeExecutor method) (executorlib.executor.single.TestClusterExecutor method) (executorlib.executor.slurm.SlurmClusterExecutor method) (executorlib.executor.slurm.SlurmJobExecutor method) (executorlib.task_scheduler.base.TaskSchedulerBase method) (executorlib.task_scheduler.file.task_scheduler.FileTaskScheduler method) (executorlib.task_scheduler.interactive.blockallocation.BlockAllocationTaskScheduler method) (executorlib.task_scheduler.interactive.dependency.DependencyTaskScheduler method) (executorlib.task_scheduler.interactive.onetoone.OneProcessTaskScheduler method) SubprocessSpawner (class in executorlib.standalone.interactive.spawner)

T

task_done() (in module executorlib.task_scheduler.interactive.shared) TaskSchedulerBase (class in executorlib.task_scheduler.base) terminate_subprocess() (in module executorlib.task_scheduler.file.spawner_subprocess)

terminate_task_in_cache() (in module executorlib) terminate_tasks_in_cache() (in module executorlib) TestClusterExecutor (class in executorlib.executor.single) threads_per_core (executorlib.standalone.validate.ResourceDictValidation attribute)

U

update_default_dict_from_arguments() (in module executorlib.standalone.interactive.backend)

update_futures_in_input() (in module executorlib.standalone.interactive.arguments)

V

validate_max_workers() (in module executorlib.task_scheduler.interactive.spawner_flux) (in module executorlib.task_scheduler.interactive.spawner_slurm) validate_number_of_cores() (in module executorlib.standalone.inputcheck)

validate_resource_dict() (in module executorlib.standalone.validate) (in module executorlib.task_scheduler.base) validate_resource_dict_with_optional_keys() (in module executorlib.standalone.validate)