parsl.executors.base.ParslExecutor

class parsl.executors.base.ParslExecutor[source]

Define the strict interface for all Executor classes.

This is a metaclass that only enforces concrete implementations of functionality by the child classes.

In addition to the listed methods, a ParslExecutor instance must always have a member field:

label: str - a human readable label for the executor, unique
with respect to other executors.

An executor may optionally expose:

storage_access: List[parsl.data_provider.staging.Staging] - a list of staging

providers that will be used for file staging. In the absence of this attribute, or if this attribute is None, then a default value of parsl.data_provider.staging.default_staging will be used by the staging code.

Typechecker note: Ideally storage_access would be declared on executor __init__ methods as List[Staging] - however, lists are by default invariant, not co-variant, and it looks like @typeguard cannot be persuaded otherwise. So if you’re implementing an executor and want to @typeguard the constructor, you’ll have to use List[Any] here.

__init__()[source]

Initialize self. See help(type(self)) for accurate signature.

Methods

scale_in(blocks) Scale in method.
scale_out(blocks) Scale out method.
shutdown() Shutdown the executor.
start() Start the executor.
submit(func, *args, **kwargs) Submit.

Attributes

run_dir Path to the run directory.
scaling_enabled Specify if scaling is enabled.