DPDispatcher API
- dpdispatcher package
JobMachineMachine.aliasMachine.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.optionsMachine.resources_arginfo()Machine.resources_subfields()Machine.serialize()Machine.sub_script_cmd()Machine.sub_script_head()Machine.subclasses_dict
ResourcesSubmissionSubmission.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
BaseContextBaseContext.aliasBaseContext.bind_submission()BaseContext.check_finish()BaseContext.clean()BaseContext.download()BaseContext.load_from_dict()BaseContext.machine_arginfo()BaseContext.machine_subfields()BaseContext.optionsBaseContext.read_file()BaseContext.subclasses_dictBaseContext.upload()BaseContext.write_file()
- dpdispatcher.dlog module
- dpdispatcher.dpdisp module
- dpdispatcher.machine module
MachineMachine.aliasMachine.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.optionsMachine.resources_arginfo()Machine.resources_subfields()Machine.serialize()Machine.sub_script_cmd()Machine.sub_script_head()Machine.subclasses_dict
- dpdispatcher.submission module
JobResourcesSubmissionSubmission.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