DPDispatcher
v0.3.1
Contents:
Install DPDispatcher
Getting Started
Machine parameters
Resources parameters
DPDispatcher API
DPDispatcher
»
Index
Edit on GitHub
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
W
|
Z
A
arginfo() (dpdispatcher.machine.Machine static method)
(dpdispatcher.ssh_context.SSHSession static method)
(dpdispatcher.submission.Resources static method)
(dpdispatcher.submission.Task static method)
B
BaseContext (class in dpdispatcher.base_context)
bind_machine() (dpdispatcher.submission.Submission method)
bind_submission() (dpdispatcher.base_context.BaseContext method)
(dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
block_call() (dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
block_checkcall() (dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
C
call() (dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
check_all_finished() (dpdispatcher.submission.Submission method)
check_file_exists() (dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
check_finish() (dpdispatcher.base_context.BaseContext method)
(dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
check_finish_tag() (dpdispatcher.lsf.LSF method)
(dpdispatcher.machine.Machine method)
(dpdispatcher.pbs.PBS method)
(dpdispatcher.shell.Shell method)
(dpdispatcher.slurm.Slurm method)
check_if_recover() (dpdispatcher.machine.Machine method)
check_status() (dpdispatcher.lsf.LSF method)
(dpdispatcher.machine.Machine method)
(dpdispatcher.pbs.PBS method)
(dpdispatcher.shell.Shell method)
(dpdispatcher.slurm.Slurm method)
check_status_() (dpdispatcher.shell.Shell method)
clean() (dpdispatcher.base_context.BaseContext method)
(dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
clean_jobs() (dpdispatcher.submission.Submission method)
close() (dpdispatcher.ssh_context.SSHContext method)
(dpdispatcher.ssh_context.SSHSession method)
completing (dpdispatcher.JobStatus.JobStatus attribute)
D
DATAERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
DBERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
default_resources() (dpdispatcher.lsf.LSF method)
(dpdispatcher.machine.Machine method)
(dpdispatcher.pbs.PBS method)
(dpdispatcher.shell.Shell method)
(dpdispatcher.slurm.Slurm method)
deserialize() (dpdispatcher.submission.Job class method)
(dpdispatcher.submission.Resources class method)
(dpdispatcher.submission.Submission class method)
(dpdispatcher.submission.Task class method)
do_submit() (dpdispatcher.lsf.LSF method)
(dpdispatcher.machine.Machine method)
(dpdispatcher.pbs.PBS method)
(dpdispatcher.shell.Shell method)
(dpdispatcher.slurm.Slurm method)
download() (dpdispatcher.base_context.BaseContext method)
(dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
download_() (dpdispatcher.local_context.LocalContext method)
download_jobs() (dpdispatcher.submission.Submission method)
dpdispatcher
module
dpdispatcher.base_context
module
dpdispatcher.dpcloudserver
module
dpdispatcher.dpcloudserver.config
module
dpdispatcher.dpcloudserver.retcode
module
dpdispatcher.dpcloudserver.zip_file
module
dpdispatcher.dpdisp
module
dpdispatcher.JobStatus
module
dpdispatcher.lazy_local_context
module
dpdispatcher.local_context
module
dpdispatcher.lsf
module
dpdispatcher.machine
module
dpdispatcher.pbs
module
dpdispatcher.shell
module
dpdispatcher.slurm
module
dpdispatcher.ssh_context
module
dpdispatcher.submission
module
E
ensure_alive() (dpdispatcher.ssh_context.SSHSession method)
exec_command() (dpdispatcher.ssh_context.SSHSession method)
F
finished (dpdispatcher.JobStatus.JobStatus attribute)
G
gen_command_env_cuda_devices() (dpdispatcher.machine.Machine method)
gen_script() (dpdispatcher.lsf.LSF method)
(dpdispatcher.machine.Machine method)
(dpdispatcher.pbs.PBS method)
(dpdispatcher.shell.Shell method)
(dpdispatcher.slurm.Slurm method)
gen_script_command() (dpdispatcher.machine.Machine method)
gen_script_custom_flags_lines() (dpdispatcher.machine.Machine method)
gen_script_end() (dpdispatcher.machine.Machine method)
gen_script_env() (dpdispatcher.machine.Machine method)
gen_script_header() (dpdispatcher.machine.Machine method)
(dpdispatcher.pbs.PBS method)
(dpdispatcher.shell.Shell method)
(dpdispatcher.slurm.Slurm method)
gen_script_wait() (dpdispatcher.machine.Machine method)
generate_jobs() (dpdispatcher.submission.Submission method)
get_hash() (dpdispatcher.submission.Job method)
(dpdispatcher.submission.Submission method)
(dpdispatcher.submission.Task method)
get_job_root() (dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
get_job_state() (dpdispatcher.submission.Job method)
get_return() (dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
get_ssh_client() (dpdispatcher.ssh_context.SSHSession method)
get_submission_state() (dpdispatcher.submission.Submission method)
H
handle_unexpected_job_state() (dpdispatcher.submission.Job method)
handle_unexpected_submission_state() (dpdispatcher.submission.Submission method)
I
info() (in module dpdispatcher)
IOERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
is_selected() (in module dpdispatcher.dpcloudserver.zip_file)
J
Job (class in dpdispatcher.submission)
job_to_json() (dpdispatcher.submission.Job method)
JobStatus (class in dpdispatcher.JobStatus)
K
kill() (dpdispatcher.base_context.BaseContext method)
(dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
L
LazyLocalContext (class in dpdispatcher.lazy_local_context)
load_from_dict() (dpdispatcher.base_context.BaseContext class method)
(dpdispatcher.lazy_local_context.LazyLocalContext class method)
(dpdispatcher.local_context.LocalContext class method)
(dpdispatcher.machine.Machine class method)
(dpdispatcher.ssh_context.SSHContext class method)
(dpdispatcher.submission.Resources class method)
load_from_json() (dpdispatcher.machine.Machine class method)
(dpdispatcher.submission.Resources class method)
LocalContext (class in dpdispatcher.local_context)
LOGINERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
LSF (class in dpdispatcher.lsf)
M
Machine (class in dpdispatcher.machine)
main() (in module dpdispatcher.dpdisp)
module
dpdispatcher
dpdispatcher.base_context
dpdispatcher.dpcloudserver
dpdispatcher.dpcloudserver.config
dpdispatcher.dpcloudserver.retcode
dpdispatcher.dpcloudserver.zip_file
dpdispatcher.dpdisp
dpdispatcher.JobStatus
dpdispatcher.lazy_local_context
dpdispatcher.local_context
dpdispatcher.lsf
dpdispatcher.machine
dpdispatcher.pbs
dpdispatcher.shell
dpdispatcher.slurm
dpdispatcher.ssh_context
dpdispatcher.submission
N
NODATA (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
O
OK (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
P
PARAMERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
PBS (class in dpdispatcher.pbs)
PWDERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
R
read() (dpdispatcher.lazy_local_context.SPRetObj method)
(dpdispatcher.local_context.SPRetObj method)
read_file() (dpdispatcher.base_context.BaseContext method)
(dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
readlines() (dpdispatcher.lazy_local_context.SPRetObj method)
(dpdispatcher.local_context.SPRetObj method)
register_job_id() (dpdispatcher.submission.Job method)
register_task() (dpdispatcher.submission.Submission method)
register_task_list() (dpdispatcher.submission.Submission method)
REQERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
Resources (class in dpdispatcher.submission)
RETCODE (class in dpdispatcher.dpcloudserver.retcode)
ROLEERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
run_submission() (dpdispatcher.submission.Submission method)
running (dpdispatcher.JobStatus.JobStatus attribute)
S
serialize() (dpdispatcher.submission.Job method)
(dpdispatcher.submission.Resources method)
(dpdispatcher.submission.Submission method)
(dpdispatcher.submission.Task method)
sftp (dpdispatcher.ssh_context.SSHContext property)
(dpdispatcher.ssh_context.SSHSession property)
Shell (class in dpdispatcher.shell)
Slurm (class in dpdispatcher.slurm)
SPRetObj (class in dpdispatcher.lazy_local_context)
(class in dpdispatcher.local_context)
ssh (dpdispatcher.ssh_context.SSHContext property)
SSHContext (class in dpdispatcher.ssh_context)
SSHSession (class in dpdispatcher.ssh_context)
sub_script_cmd() (dpdispatcher.machine.Machine method)
sub_script_head() (dpdispatcher.machine.Machine method)
subclasses_dict (dpdispatcher.base_context.BaseContext attribute)
(dpdispatcher.machine.Machine attribute)
Submission (class in dpdispatcher.submission)
submission_from_json() (dpdispatcher.submission.Submission class method)
submission_to_json() (dpdispatcher.submission.Submission method)
submit_job() (dpdispatcher.submission.Job method)
T
Task (class in dpdispatcher.submission)
terminated (dpdispatcher.JobStatus.JobStatus attribute)
THIRDERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
try_recover_from_json() (dpdispatcher.submission.Submission method)
U
UNDERDEBUG (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
unknown (dpdispatcher.JobStatus.JobStatus attribute)
UNKOWNERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
unsubmitted (dpdispatcher.JobStatus.JobStatus attribute)
unzip_file() (in module dpdispatcher.dpcloudserver.zip_file)
upload() (dpdispatcher.base_context.BaseContext method)
(dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
upload_() (dpdispatcher.local_context.LocalContext method)
upload_jobs() (dpdispatcher.submission.Submission method)
USERERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
V
VERIFYERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
W
waiting (dpdispatcher.JobStatus.JobStatus attribute)
write_file() (dpdispatcher.base_context.BaseContext method)
(dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
Z
zip_file_list() (in module dpdispatcher.dpcloudserver.zip_file)
zip_files() (in module dpdispatcher.dpcloudserver.zip_file)
Read the Docs
v: v0.3.1
Versions
latest
stable
v0.3.1
v0.3.0
v0.2.8
v0.2.7
v0.2.6
v0.2.5
v0.2.4
v0.2.3
v0.2.2
v0.2.1
v0.2.0
v0.1.1
v0.1.0
Downloads
On Read the Docs
Project Home
Builds