DPDispatcher API
- dpdispatcher package
Job
Machine
Machine.alias
Machine.arginfo()
Machine.bind_context()
Machine.check_finish_tag()
Machine.check_if_recover()
Machine.check_status()
Machine.default_resources()
Machine.deserialize()
Machine.do_submit()
Machine.gen_command_env_cuda_devices()
Machine.gen_script()
Machine.gen_script_command()
Machine.gen_script_custom_flags_lines()
Machine.gen_script_end()
Machine.gen_script_env()
Machine.gen_script_header()
Machine.gen_script_run_command()
Machine.gen_script_wait()
Machine.get_exit_code()
Machine.kill()
Machine.load_from_dict()
Machine.load_from_json()
Machine.load_from_yaml()
Machine.options
Machine.resources_arginfo()
Machine.resources_subfields()
Machine.serialize()
Machine.sub_script_cmd()
Machine.sub_script_head()
Machine.subclasses_dict
Resources
Submission
Submission.async_run_submission()
Submission.bind_machine()
Submission.check_all_finished()
Submission.check_ratio_unfinished()
Submission.clean_jobs()
Submission.deserialize()
Submission.download_jobs()
Submission.generate_jobs()
Submission.get_hash()
Submission.handle_unexpected_submission_state()
Submission.register_task()
Submission.register_task_list()
Submission.remove_unfinished_tasks()
Submission.run_submission()
Submission.serialize()
Submission.submission_from_json()
Submission.submission_to_json()
Submission.try_download_result()
Submission.try_recover_from_json()
Submission.update_submission_state()
Submission.upload_jobs()
Task
- Subpackages
- dpdispatcher.contexts package
- dpdispatcher.dpcloudserver package
- dpdispatcher.entrypoints package
- dpdispatcher.machines package
- Submodules
- dpdispatcher.machines.distributed_shell module
- dpdispatcher.machines.dp_cloud_server module
- dpdispatcher.machines.fugaku module
- dpdispatcher.machines.lsf module
- dpdispatcher.machines.openapi module
- dpdispatcher.machines.pbs module
- dpdispatcher.machines.shell module
- dpdispatcher.machines.slurm module
- dpdispatcher.utils package
- Submodules
- dpdispatcher.arginfo module
- dpdispatcher.base_context module
BaseContext
BaseContext.alias
BaseContext.bind_submission()
BaseContext.check_finish()
BaseContext.clean()
BaseContext.download()
BaseContext.load_from_dict()
BaseContext.machine_arginfo()
BaseContext.machine_subfields()
BaseContext.options
BaseContext.read_file()
BaseContext.subclasses_dict
BaseContext.upload()
BaseContext.write_file()
- dpdispatcher.dlog module
- dpdispatcher.dpdisp module
- dpdispatcher.machine module
Machine
Machine.alias
Machine.arginfo()
Machine.bind_context()
Machine.check_finish_tag()
Machine.check_if_recover()
Machine.check_status()
Machine.default_resources()
Machine.deserialize()
Machine.do_submit()
Machine.gen_command_env_cuda_devices()
Machine.gen_script()
Machine.gen_script_command()
Machine.gen_script_custom_flags_lines()
Machine.gen_script_end()
Machine.gen_script_env()
Machine.gen_script_header()
Machine.gen_script_run_command()
Machine.gen_script_wait()
Machine.get_exit_code()
Machine.kill()
Machine.load_from_dict()
Machine.load_from_json()
Machine.load_from_yaml()
Machine.options
Machine.resources_arginfo()
Machine.resources_subfields()
Machine.serialize()
Machine.sub_script_cmd()
Machine.sub_script_head()
Machine.subclasses_dict
- dpdispatcher.submission module
Job
Resources
Submission
Submission.async_run_submission()
Submission.bind_machine()
Submission.check_all_finished()
Submission.check_ratio_unfinished()
Submission.clean_jobs()
Submission.deserialize()
Submission.download_jobs()
Submission.generate_jobs()
Submission.get_hash()
Submission.handle_unexpected_submission_state()
Submission.register_task()
Submission.register_task_list()
Submission.remove_unfinished_tasks()
Submission.run_submission()
Submission.serialize()
Submission.submission_from_json()
Submission.submission_to_json()
Submission.try_download_result()
Submission.try_recover_from_json()
Submission.update_submission_state()
Submission.upload_jobs()
Task