parsl.providers.cluster_provider.ClusterProvider¶
-
class
parsl.providers.cluster_provider.
ClusterProvider
(label, channel, nodes_per_block, init_blocks, min_blocks, max_blocks, parallelism, walltime, launcher, cmd_timeout=10)[source]¶ This class defines behavior common to all cluster/supercompute-style scheduler systems.
- Parameters
label (str) – Label for this provider.
channel (Channel) – Channel for accessing this provider. Possible channels include
LocalChannel
(the default),SSHChannel
, orSSHInteractiveLoginChannel
.walltime (str) – Walltime requested per block in HH:MM:SS.
launcher (str) – FIXME
cmd_timeout (int) – Timeout for commands made to the scheduler in seconds
+------------------ | script_string ------->| submit id <--------|---+ | [ ids ] ------->| status [statuses] <--------|----+ | [ ids ] ------->| cancel [cancel] <--------|----+ | +-------------------
-
__init__
(label, channel, nodes_per_block, init_blocks, min_blocks, max_blocks, parallelism, walltime, launcher, cmd_timeout=10)[source]¶ Initialize self. See help(type(self)) for accurate signature.
Methods
__init__
(label, channel, nodes_per_block, …)Initialize self.
cancel
(job_ids)Cancels the resources identified by the job_ids provided by the user.
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])The submit method takes the command string to be executed upon instantiation of a resource most often to start a pilot (such as IPP engine or even Swift-T engines).
Attributes
cores_per_node
Number of cores to provision per node.
label
Provides the label for this provider
mem_per_node
Real memory to provision per node in GB.
status_polling_interval
Returns the interval, in seconds, at which the status method should be called.