psimulate
Parallel runner for vivarium jobs.
- Branch and Keyspace Management
Keyspacecalculate_input_draws()calculate_random_seeds()calculate_keyspace()load_branch_configuration()expand_branch_templates()validate_artifact_path()- psimulate CLI
- Environment Variables
EnvVariable- psimulate Jobs
generate_task_id()JobParametersJobParameters.model_specificationJobParameters.branch_configurationJobParameters.input_drawJobParameters.random_seedJobParameters.results_pathJobParameters.worker_logging_rootJobParameters.backup_configurationJobParameters.extrasJobParameters.task_idJobParameters.sharedJobParameters.job_specificJobParameters.sim_configJobParameters.to_dict()
build_job_list()already_complete()- Model specification management
parse()persist()- File Path Management
InputPathsOutputPathsOutputPaths.rootOutputPaths.logging_rootOutputPaths.worker_logging_rootOutputPaths.metadata_dirOutputPaths.environment_fileOutputPaths.model_specificationOutputPaths.keyspaceOutputPaths.branchesOutputPaths.results_dirOutputPaths.backup_dirOutputPaths.backup_metadata_pathOutputPaths.artifact_nameOutputPaths.run_dateOutputPaths.run_typeOutputPaths.original_run_dateOutputPaths.project_nameOutputPaths.root_pathOutputPaths.logging_to_central_results_directoryOutputPaths.from_entry_point_args()OutputPaths.touch()
transform_perf_df_for_appending()append_child_job_data()generate_runner_job_data()append_perf_data_to_central_logs()- Reproducible Programming Environments
validate()- psimulate Runner
report_initial_status()try_run_vipin()write_backup_metadata()write_configuration()main()- Cluster Interaction
- Cluster CLI options
with_queue_and_max_runtime()- Cluster Interface
validate_cluster_environment()NativeSpecificationget_workflow_timeout_seconds()- Results Management
- Results CLI Options
- Results Writing
write_metadata()write_task_results()get_completed_task_ids()collect_metadata()- psimulate Workers
- Load Test Worker
get_psimulate_test_dict()sleep_test()large_results_test()work_horse()- Jobmon Task Runner
parse_args()main()- Vivarium Worker
ParallelSimulationContextwork_horse()get_backup()get_sim_from_backup()initialize_new_sim()run_simulation()get_sim_results()do_sim_epilogue()remove_backups()