with_verbose_and_pdb()
coerce_to_full_path()
pass_shared_options()
add_logging_sink()
configure_main_process_logging_to_terminal()
configure_main_process_logging_to_file()
get_cluster_name()
get_drmaa()
mkdir()
backoff_and_retry()
Keyspace
calculate_input_draws()
calculate_random_seeds()
calculate_keyspace()
load_branch_configuration()
expand_branch_templates()
validate_artifact_path()
EnvVariable
JobParameters
build_job_list()
already_complete()
parse()
persist()
InputPaths
OutputPaths
validate()
process_job_results()
load_existing_outputs()
report_initial_status()
try_run_vipin()
main()
with_queue_and_max_runtime()
validate_cluster_environment()
NativeSpecification
submit_worker_jobs()
launch_redis_processes()
QueueManager
RegistryManager
write_results_batch()
build_launch_script()
work_horse()
setup_sim()
do_sim_epilogue()
parameter_update_format()
Creates redis databases to store job parameters and results.
num_processes (int) –
num_workers (int) –
redis_logging_root (Path) –
List[Tuple[str, int]]