Home
Blog
Tutorials
Docs
DeePMD-kit
DP-GEN
dpdata
DPDispatcher
ABACUS
DeepFlame
Publications
GitHub
Home
Blog
Tutorials
Docs
Publications
GitHub
DPDispatcher
v0.5.4
Contents:
Install DPDispatcher
Getting Started
Supported contexts
Supported batch job systems
Machine parameters
Resources parameters
Task parameters
DPDispatcher API
Examples
Running the DeePMD-kit on the Expanse cluster
Running Gaussian 16 with failure allowed
Running multiple MD tasks on a GPU workstation
Project details
Authors
DPDispatcher
Index
Edit on GitHub
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
|
Z
A
alias (dpdispatcher.base_context.BaseContext attribute)
(dpdispatcher.dp_cloud_server.Bohrium attribute)
(dpdispatcher.dp_cloud_server_context.BohriumContext attribute)
(dpdispatcher.machine.Machine attribute)
append_script:
resources/append_script (Argument)
arginfo() (dpdispatcher.machine.Machine class method)
(dpdispatcher.ssh_context.SSHSession static method)
(dpdispatcher.submission.Resources static method)
(dpdispatcher.submission.Task static method)
B
backward_files:
task/backward_files (Argument)
BaseContext (class in dpdispatcher.base_context)
batch_type:
machine/batch_type (Argument)
resources/batch_type (Argument)
bind_context() (dpdispatcher.machine.Machine method)
bind_machine() (dpdispatcher.submission.Submission method)
bind_submission() (dpdispatcher.base_context.BaseContext method)
(dpdispatcher.dp_cloud_server_context.BohriumContext method)
(dpdispatcher.hdfs_context.HDFSContext 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)
Bohrium (class in dpdispatcher.dp_cloud_server)
BohriumContext (class in dpdispatcher.dp_cloud_server_context)
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.dp_cloud_server_context.BohriumContext method)
(dpdispatcher.hdfs_context.HDFSContext method)
(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.distributed_shell.DistributedShell method)
(dpdispatcher.dp_cloud_server.Bohrium method)
(dpdispatcher.lsf.LSF method)
(dpdispatcher.machine.Machine method)
(dpdispatcher.pbs.PBS method)
(dpdispatcher.shell.Shell method)
(dpdispatcher.slurm.Slurm method)
(dpdispatcher.slurm.SlurmJobArray method)
check_home_file_exits() (dpdispatcher.dp_cloud_server_context.BohriumContext method)
check_if_recover() (dpdispatcher.dp_cloud_server.Bohrium method)
(dpdispatcher.machine.Machine method)
check_ratio_unfinished() (dpdispatcher.submission.Submission method)
check_status() (dpdispatcher.distributed_shell.DistributedShell method)
(dpdispatcher.dp_cloud_server.Bohrium method)
(dpdispatcher.lsf.LSF method)
(dpdispatcher.machine.Machine method)
(dpdispatcher.pbs.PBS method)
(dpdispatcher.pbs.Torque method)
(dpdispatcher.shell.Shell method)
(dpdispatcher.slurm.Slurm method)
(dpdispatcher.slurm.SlurmJobArray method)
clean() (dpdispatcher.base_context.BaseContext method)
(dpdispatcher.dp_cloud_server_context.BohriumContext method)
(dpdispatcher.hdfs_context.HDFSContext method)
(dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
clean_asynchronously:
machine/clean_asynchronously (Argument)
clean_jobs() (dpdispatcher.submission.Submission method)
Client (class in dpdispatcher.dpcloudserver.client)
close() (dpdispatcher.ssh_context.SSHContext method)
(dpdispatcher.ssh_context.SSHSession method)
command:
task/command (Argument)
completing (dpdispatcher.JobStatus.JobStatus attribute)
context_type:
machine/context_type (Argument)
copy_from_local() (dpdispatcher.hdfs_cli.HDFS static method)
copy_to_local() (dpdispatcher.hdfs_cli.HDFS static method)
cpu_per_node:
resources/cpu_per_node (Argument)
custom_flags:
resources/custom_flags (Argument)
custom_gpu_line:
resources[LSF]/kwargs/custom_gpu_line (Argument)
resources[Slurm]/kwargs/custom_gpu_line (Argument)
resources[SlurmJobArray]/kwargs/custom_gpu_line (Argument)
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.machine.Machine class method)
(dpdispatcher.submission.Job class method)
(dpdispatcher.submission.Resources class method)
(dpdispatcher.submission.Submission class method)
(dpdispatcher.submission.Task class method)
DistributedShell (class in dpdispatcher.distributed_shell)
do_submit() (dpdispatcher.distributed_shell.DistributedShell method)
(dpdispatcher.dp_cloud_server.Bohrium method)
(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.dp_cloud_server_context.BohriumContext method)
(dpdispatcher.dpcloudserver.client.Client method)
(dpdispatcher.hdfs_context.HDFSContext method)
(dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
download_from_url() (dpdispatcher.dpcloudserver.client.Client method)
download_jobs() (dpdispatcher.submission.Submission method)
DpCloudServer (in module dpdispatcher.dp_cloud_server)
DpCloudServerContext (in module dpdispatcher.dp_cloud_server_context)
dpdispatcher
module
dpdispatcher.arginfo
module
dpdispatcher.base_context
module
dpdispatcher.distributed_shell
module
dpdispatcher.dp_cloud_server
module
dpdispatcher.dp_cloud_server_context
module
dpdispatcher.dpcloudserver
module
dpdispatcher.dpcloudserver.client
module
dpdispatcher.dpcloudserver.config
module
dpdispatcher.dpcloudserver.retcode
module
dpdispatcher.dpcloudserver.zip_file
module
dpdispatcher.dpdisp
module
dpdispatcher.hdfs_cli
module
dpdispatcher.hdfs_context
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
dpdispatcher.utils
module
E
email:
machine[BohriumContext]/remote_profile/email (Argument)
ensure_alive() (dpdispatcher.ssh_context.SSHSession method)
envs:
resources/envs (Argument)
errlog:
task/errlog (Argument)
exec_command() (dpdispatcher.ssh_context.SSHSession method)
exists() (dpdispatcher.hdfs_cli.HDFS static method)
F
finished (dpdispatcher.JobStatus.JobStatus attribute)
forward_files:
task/forward_files (Argument)
G
gen_command_env_cuda_devices() (dpdispatcher.machine.Machine method)
gen_local_script() (dpdispatcher.dp_cloud_server.Bohrium method)
gen_script() (dpdispatcher.dp_cloud_server.Bohrium method)
(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)
(dpdispatcher.slurm.SlurmJobArray method)
gen_script_custom_flags_lines() (dpdispatcher.machine.Machine method)
gen_script_end() (dpdispatcher.distributed_shell.DistributedShell method)
(dpdispatcher.machine.Machine method)
(dpdispatcher.slurm.SlurmJobArray method)
gen_script_env() (dpdispatcher.distributed_shell.DistributedShell method)
(dpdispatcher.machine.Machine method)
gen_script_header() (dpdispatcher.distributed_shell.DistributedShell method)
(dpdispatcher.dp_cloud_server.Bohrium method)
(dpdispatcher.lsf.LSF method)
(dpdispatcher.machine.Machine method)
(dpdispatcher.pbs.PBS method)
(dpdispatcher.pbs.Torque method)
(dpdispatcher.shell.Shell method)
(dpdispatcher.slurm.Slurm method)
(dpdispatcher.slurm.SlurmJobArray method)
gen_script_wait() (dpdispatcher.machine.Machine method)
generate_jobs() (dpdispatcher.submission.Submission method)
generate_totp() (in module dpdispatcher.utils)
get() (dpdispatcher.dpcloudserver.client.Client method)
(dpdispatcher.ssh_context.SSHSession method)
get_hash() (dpdispatcher.submission.Job method)
(dpdispatcher.submission.Submission method)
(dpdispatcher.submission.Task method)
get_job_detail() (dpdispatcher.dpcloudserver.client.Client method)
get_job_result_url() (dpdispatcher.dpcloudserver.client.Client method)
get_job_root() (dpdispatcher.hdfs_context.HDFSContext method)
(dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
get_job_state() (dpdispatcher.submission.Job method)
get_log() (dpdispatcher.dpcloudserver.client.Client method)
get_return() (dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
get_sha256() (in module dpdispatcher.utils)
get_ssh_client() (dpdispatcher.ssh_context.SSHSession method)
get_tasks_list() (dpdispatcher.dpcloudserver.client.Client method)
gpu_exclusive:
resources[LSF]/kwargs/gpu_exclusive (Argument)
gpu_new_syntax:
resources[LSF]/kwargs/gpu_new_syntax (Argument)
gpu_per_node:
resources/gpu_per_node (Argument)
gpu_usage:
resources[LSF]/kwargs/gpu_usage (Argument)
group_size:
resources/group_size (Argument)
H
handle_unexpected_job_state() (dpdispatcher.submission.Job method)
handle_unexpected_submission_state() (dpdispatcher.submission.Submission method)
HDFS (class in dpdispatcher.hdfs_cli)
HDFSContext (class in dpdispatcher.hdfs_context)
hostname:
machine[SSHContext]/remote_profile/hostname (Argument)
hotp() (in module dpdispatcher.utils)
I
if_cuda_multi_devices:
resources/strategy/if_cuda_multi_devices (Argument)
info() (in module dpdispatcher)
input_data:
machine[BohriumContext]/remote_profile/input_data (Argument)
inter_handler() (dpdispatcher.ssh_context.SSHSession method)
IOERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
J
Job (class in dpdispatcher.submission)
job_create() (dpdispatcher.dpcloudserver.client.Client method)
job_to_json() (dpdispatcher.submission.Job method)
JobStatus (class in dpdispatcher.JobStatus)
K
keep_backup:
machine[BohriumContext]/remote_profile/keep_backup (Argument)
key_filename:
machine[SSHContext]/remote_profile/key_filename (Argument)
kill() (dpdispatcher.base_context.BaseContext method)
(dpdispatcher.dp_cloud_server_context.BohriumContext method)
(dpdispatcher.hdfs_context.HDFSContext method)
(dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
kwargs:
resources[Bohrium]/kwargs (Argument)
resources[DistributedShell]/kwargs (Argument)
resources[LSF]/kwargs (Argument)
resources[PBS]/kwargs (Argument)
resources[Shell]/kwargs (Argument)
resources[Slurm]/kwargs (Argument)
resources[SlurmJobArray]/kwargs (Argument)
resources[Torque]/kwargs (Argument)
L
LazyLocalContext (class in dpdispatcher.lazy_local_context)
Lebesgue (in module dpdispatcher.dp_cloud_server)
LebesgueContext (in module dpdispatcher.dp_cloud_server_context)
load_from_dict() (dpdispatcher.base_context.BaseContext class method)
(dpdispatcher.dp_cloud_server_context.BohriumContext class method)
(dpdispatcher.hdfs_context.HDFSContext 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)
(dpdispatcher.submission.Task class method)
load_from_json() (dpdispatcher.machine.Machine class method)
(dpdispatcher.submission.Resources class method)
(dpdispatcher.submission.Task class method)
local_root:
machine/local_root (Argument)
LocalContext (class in dpdispatcher.local_context)
look_for_keys:
machine[SSHContext]/remote_profile/look_for_keys (Argument)
LSF (class in dpdispatcher.lsf)
M
machine (Argument)
machine:
Machine (class in dpdispatcher.machine)
machine/batch_type (Argument)
batch_type:
machine/clean_asynchronously (Argument)
clean_asynchronously:
machine/context_type (Argument)
context_type:
machine/local_root (Argument)
local_root:
machine/remote_root (Argument)
remote_root:
machine:
machine (Argument)
machine[BohriumContext]/remote_profile (Argument)
remote_profile:
machine[BohriumContext]/remote_profile/email (Argument)
email:
machine[BohriumContext]/remote_profile/input_data (Argument)
input_data:
machine[BohriumContext]/remote_profile/keep_backup (Argument)
keep_backup:
machine[BohriumContext]/remote_profile/password (Argument)
password:
machine[BohriumContext]/remote_profile/program_id (Argument)
program_id:
machine[HDFSContext]/remote_profile (Argument)
remote_profile:
machine[LazyLocalContext]/remote_profile (Argument)
remote_profile:
machine[LocalContext]/remote_profile (Argument)
remote_profile:
machine[SSHContext]/remote_profile (Argument)
remote_profile:
machine[SSHContext]/remote_profile/hostname (Argument)
hostname:
machine[SSHContext]/remote_profile/key_filename (Argument)
key_filename:
machine[SSHContext]/remote_profile/look_for_keys (Argument)
look_for_keys:
machine[SSHContext]/remote_profile/passphrase (Argument)
passphrase:
machine[SSHContext]/remote_profile/password (Argument)
password:
machine[SSHContext]/remote_profile/port (Argument)
port:
machine[SSHContext]/remote_profile/tar_compress (Argument)
tar_compress:
machine[SSHContext]/remote_profile/timeout (Argument)
timeout:
machine[SSHContext]/remote_profile/totp_secret (Argument)
totp_secret:
machine[SSHContext]/remote_profile/username (Argument)
username:
machine_arginfo() (dpdispatcher.base_context.BaseContext class method)
machine_subfields() (dpdispatcher.base_context.BaseContext class method)
(dpdispatcher.dp_cloud_server_context.BohriumContext class method)
(dpdispatcher.ssh_context.SSHContext class method)
main() (in module dpdispatcher.dpdisp)
map_dp_job_state() (dpdispatcher.dp_cloud_server.Bohrium static method)
mkdir() (dpdispatcher.hdfs_cli.HDFS static method)
module
dpdispatcher
dpdispatcher.arginfo
dpdispatcher.base_context
dpdispatcher.distributed_shell
dpdispatcher.dp_cloud_server
dpdispatcher.dp_cloud_server_context
dpdispatcher.dpcloudserver
dpdispatcher.dpcloudserver.client
dpdispatcher.dpcloudserver.config
dpdispatcher.dpcloudserver.retcode
dpdispatcher.dpcloudserver.zip_file
dpdispatcher.dpdisp
dpdispatcher.hdfs_cli
dpdispatcher.hdfs_context
dpdispatcher.JobStatus
dpdispatcher.lazy_local_context
dpdispatcher.local_context
dpdispatcher.lsf
dpdispatcher.machine
dpdispatcher.pbs
dpdispatcher.shell
dpdispatcher.slurm
dpdispatcher.ssh_context
dpdispatcher.submission
dpdispatcher.utils
module_list:
resources/module_list (Argument)
module_purge:
resources/module_purge (Argument)
module_unload_list:
resources/module_unload_list (Argument)
move() (dpdispatcher.hdfs_cli.HDFS static method)
N
NODATA (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
number_node:
resources/number_node (Argument)
O
OK (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
options (dpdispatcher.base_context.BaseContext attribute)
(dpdispatcher.machine.Machine attribute)
outlog:
task/outlog (Argument)
P
para_deg:
resources/para_deg (Argument)
PARAMERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
passphrase:
machine[SSHContext]/remote_profile/passphrase (Argument)
password:
machine[BohriumContext]/remote_profile/password (Argument)
machine[SSHContext]/remote_profile/password (Argument)
PBS (class in dpdispatcher.pbs)
port:
machine[SSHContext]/remote_profile/port (Argument)
post() (dpdispatcher.dpcloudserver.client.Client method)
prepend_script:
resources/prepend_script (Argument)
program_id:
machine[BohriumContext]/remote_profile/program_id (Argument)
put() (dpdispatcher.ssh_context.SSHSession method)
PWDERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
Q
queue_name:
resources/queue_name (Argument)
R
ratio_unfinished:
resources/strategy/ratio_unfinished (Argument)
read() (dpdispatcher.lazy_local_context.SPRetObj method)
(dpdispatcher.local_context.SPRetObj method)
read_file() (dpdispatcher.base_context.BaseContext method)
(dpdispatcher.dp_cloud_server_context.BohriumContext method)
(dpdispatcher.hdfs_context.HDFSContext method)
(dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
read_hdfs_file() (dpdispatcher.hdfs_cli.HDFS static method)
read_home_file() (dpdispatcher.dp_cloud_server_context.BohriumContext method)
readlines() (dpdispatcher.lazy_local_context.SPRetObj method)
(dpdispatcher.local_context.SPRetObj method)
refresh_token() (dpdispatcher.dpcloudserver.client.Client method)
register_job_id() (dpdispatcher.submission.Job method)
register_task() (dpdispatcher.submission.Submission method)
register_task_list() (dpdispatcher.submission.Submission method)
remote (dpdispatcher.ssh_context.SSHSession property)
remote_profile:
machine[BohriumContext]/remote_profile (Argument)
machine[HDFSContext]/remote_profile (Argument)
machine[LazyLocalContext]/remote_profile (Argument)
machine[LocalContext]/remote_profile (Argument)
machine[SSHContext]/remote_profile (Argument)
remote_root:
machine/remote_root (Argument)
remove() (dpdispatcher.hdfs_cli.HDFS static method)
remove_unfinished_jobs() (dpdispatcher.submission.Submission method)
REQERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
RequestInfoException
resources (Argument)
resources:
Resources (class in dpdispatcher.submission)
resources/append_script (Argument)
append_script:
resources/batch_type (Argument)
batch_type:
resources/cpu_per_node (Argument)
cpu_per_node:
resources/custom_flags (Argument)
custom_flags:
resources/envs (Argument)
envs:
resources/gpu_per_node (Argument)
gpu_per_node:
resources/group_size (Argument)
group_size:
resources/module_list (Argument)
module_list:
resources/module_purge (Argument)
module_purge:
resources/module_unload_list (Argument)
module_unload_list:
resources/number_node (Argument)
number_node:
resources/para_deg (Argument)
para_deg:
resources/prepend_script (Argument)
prepend_script:
resources/queue_name (Argument)
queue_name:
resources/source_list (Argument)
source_list:
resources/strategy (Argument)
strategy:
resources/strategy/if_cuda_multi_devices (Argument)
if_cuda_multi_devices:
resources/strategy/ratio_unfinished (Argument)
ratio_unfinished:
resources/wait_time (Argument)
wait_time:
resources:
resources (Argument)
resources[Bohrium]/kwargs (Argument)
kwargs:
resources[DistributedShell]/kwargs (Argument)
kwargs:
resources[LSF]/kwargs (Argument)
kwargs:
resources[LSF]/kwargs/custom_gpu_line (Argument)
custom_gpu_line:
resources[LSF]/kwargs/gpu_exclusive (Argument)
gpu_exclusive:
resources[LSF]/kwargs/gpu_new_syntax (Argument)
gpu_new_syntax:
resources[LSF]/kwargs/gpu_usage (Argument)
gpu_usage:
resources[PBS]/kwargs (Argument)
kwargs:
resources[Shell]/kwargs (Argument)
kwargs:
resources[Slurm]/kwargs (Argument)
kwargs:
resources[Slurm]/kwargs/custom_gpu_line (Argument)
custom_gpu_line:
resources[SlurmJobArray]/kwargs (Argument)
kwargs:
resources[SlurmJobArray]/kwargs/custom_gpu_line (Argument)
custom_gpu_line:
resources[Torque]/kwargs (Argument)
kwargs:
resources_arginfo() (dpdispatcher.machine.Machine class method)
resources_subfields() (dpdispatcher.lsf.LSF class method)
(dpdispatcher.machine.Machine class method)
(dpdispatcher.slurm.Slurm class method)
RETCODE (class in dpdispatcher.dpcloudserver.retcode)
retry() (in module dpdispatcher.utils)
RetrySignal
ROLEERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
rsync() (in module dpdispatcher.utils)
rsync_available (dpdispatcher.ssh_context.SSHSession property)
run_cmd_with_all_output() (in module dpdispatcher.utils)
run_submission() (dpdispatcher.submission.Submission method)
running (dpdispatcher.JobStatus.JobStatus attribute)
S
serialize() (dpdispatcher.machine.Machine method)
(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)
SlurmJobArray (class in dpdispatcher.slurm)
source_list:
resources/source_list (Argument)
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)
strategy:
resources/strategy (Argument)
sub_script_cmd() (dpdispatcher.lsf.LSF method)
(dpdispatcher.machine.Machine method)
sub_script_head() (dpdispatcher.lsf.LSF method)
(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
tar_compress:
machine[SSHContext]/remote_profile/tar_compress (Argument)
task (Argument)
task:
Task (class in dpdispatcher.submission)
task/backward_files (Argument)
backward_files:
task/command (Argument)
command:
task/errlog (Argument)
errlog:
task/forward_files (Argument)
forward_files:
task/outlog (Argument)
outlog:
task/task_work_path (Argument)
task_work_path:
task:
task (Argument)
task_work_path:
task/task_work_path (Argument)
terminated (dpdispatcher.JobStatus.JobStatus attribute)
THIRDERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
timeout:
machine[SSHContext]/remote_profile/timeout (Argument)
TOKENINVALID (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
Torque (class in dpdispatcher.pbs)
totp_secret:
machine[SSHContext]/remote_profile/totp_secret (Argument)
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)
update_submission_state() (dpdispatcher.submission.Submission method)
upload() (dpdispatcher.base_context.BaseContext method)
(dpdispatcher.dp_cloud_server_context.BohriumContext method)
(dpdispatcher.dpcloudserver.client.Client method)
(dpdispatcher.hdfs_context.HDFSContext method)
(dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
upload_job() (dpdispatcher.dp_cloud_server_context.BohriumContext method)
upload_jobs() (dpdispatcher.submission.Submission method)
USERERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
username:
machine[SSHContext]/remote_profile/username (Argument)
V
VERIFYERR (dpdispatcher.dpcloudserver.retcode.RETCODE attribute)
W
wait_time:
resources/wait_time (Argument)
waiting (dpdispatcher.JobStatus.JobStatus attribute)
write_file() (dpdispatcher.base_context.BaseContext method)
(dpdispatcher.dp_cloud_server_context.BohriumContext method)
(dpdispatcher.hdfs_context.HDFSContext method)
(dpdispatcher.lazy_local_context.LazyLocalContext method)
(dpdispatcher.local_context.LocalContext method)
(dpdispatcher.ssh_context.SSHContext method)
write_home_file() (dpdispatcher.dp_cloud_server_context.BohriumContext method)
write_local_file() (dpdispatcher.dp_cloud_server_context.BohriumContext method)
Z
zip_file_list() (in module dpdispatcher.dpcloudserver.zip_file)
Read the Docs
v: v0.5.4
Versions
latest
stable
v0.5.4
v0.5.3
v0.5.2
v0.5.1
v0.5.0
v0.4.19
v0.4.18
v0.4.17
v0.4.16
v0.4.15
v0.4.14
v0.4.13
v0.4.12
v0.4.11
v0.4.10
v0.4.9
v0.4.8
v0.4.7
v0.4.6
v0.4.5
v0.4.4
v0.4.3
v0.4.2
v0.4.1
0.4.0
v0.3.46
v0.3.45
v0.3.44
v0.3.43
v0.3.42
v0.3.41
v0.3.40
v0.3.39
v0.3.38
v0.3.37
v0.3.36
v0.3.35
v0.3.34
v0.3.33
v0.3.32
v0.3.31
v0.3.30
v0.3.29
v0.3.28
v0.3.27
v0.3.26
v0.3.25
v0.3.24
v0.3.23
v0.3.22
v0.3.21
v0.3.20
v0.3.19
v0.3.18
v0.3.17
v0.3.16
v0.3.15
v0.3.14
v0.3.13
v0.3.12
v0.3.11
v0.3.10
v0.3.9
v0.3.8
v0.3.7
v0.3.6
v0.3.5
v0.3.4
v0.3.3
v0.3.2
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