parsl.providers.CobaltProvider¶
-
class
parsl.providers.
CobaltProvider
(channel=LocalChannel( envs={}, script_dir=None, userhome='/home/docs/checkouts/readthedocs.org/user_builds/parsl/checkouts/0.9.0/docs' ), nodes_per_block=1, init_blocks=0, min_blocks=0, max_blocks=10, parallelism=1, walltime='00:10:00', account=None, queue=None, scheduler_options='', worker_init='', launcher=AprunLauncher(overrides=''), cmd_timeout=10)[source]¶ Cobalt Execution Provider
This provider uses cobalt to submit (qsub), obtain the status of (qstat), and cancel (qdel) jobs. Theo script to be used is created from a template file in this same module.
Parameters: - channel (Channel) – Channel for accessing this provider. Possible channels include
LocalChannel
(the default),SSHChannel
, orSSHInteractiveLoginChannel
. - nodes_per_block (int) – Nodes to provision per block.
- min_blocks (int) – Minimum number of blocks to maintain.
- max_blocks (int) – Maximum number of blocks to maintain.
- walltime (str) – Walltime requested per block in HH:MM:SS.
- account (str) – Account that the job will be charged against.
- queue (str) – Torque queue to request blocks from.
- scheduler_options (str) – String to prepend to the submit script to the scheduler.
- worker_init (str) – Command to be run before starting a worker, such as ‘module load Anaconda; source activate env’.
- launcher (Launcher) – Launcher for this provider. Possible launchers include
AprunLauncher
(the default) or,SingleNodeLauncher
-
__init__
(channel=LocalChannel( envs={}, script_dir=None, userhome='/home/docs/checkouts/readthedocs.org/user_builds/parsl/checkouts/0.9.0/docs' ), nodes_per_block=1, init_blocks=0, min_blocks=0, max_blocks=10, parallelism=1, walltime='00:10:00', account=None, queue=None, scheduler_options='', worker_init='', launcher=AprunLauncher(overrides=''), cmd_timeout=10)[source]¶ Initialize self. See help(type(self)) for accurate signature.
Methods
__init__
([channel, nodes_per_block, …])Initialize self. cancel
(job_ids)Cancels the jobs specified by a list of job ids execute_wait
(cmd[, timeout])status
(job_ids)Get the status of a list of jobs identified by the job identifiers returned from the submit request. submit
(command, tasks_per_node[, job_name])Submits the command onto an Local Resource Manager job of parallel elements. Attributes
current_capacity
Returns the currently provisioned blocks. label
Provides the label for this provider CobaltProvider.scaling_enabled
- channel (Channel) – Channel for accessing this provider. Possible channels include