ThreadPoolExecutor(label: str = 'threads', max_threads: int = 2, thread_name_prefix: str = '', storage_access: List[Any] = None, working_dir: Optional[str] = None, managed: bool = True)¶
A thread-based executor.
max_threads (int) – Number of threads. Default is 2.
thread_name_prefix (string) – Thread name prefix (only supported in python v3.6+).
storage_access (list of
Staging) – Specifications for accessing data this executor remotely.
managed (bool) – If True, parsl will control dynamic scaling of this executor, and be responsible. Otherwise, this is managed by the user.
__init__(label: str = 'threads', max_threads: int = 2, thread_name_prefix: str = '', storage_access: List[Any] = None, working_dir: Optional[str] = None, managed: bool = True)¶
Initialize self. See help(type(self)) for accurate signature.
__init__([label, max_threads, …])
This method is called by the error management infrastructure after a status poll.
Scale in the number of active blocks by specified amount.
Scales out the number of active workers by 1.
Allows external error handlers to mark this executor as irrecoverably bad and cause all tasks submitted to it now and in the future to fail.
Shutdown the ThreadPool.
Start the executor.
Return the status of all jobs/blocks currently known to this executor.
submit(func, resource_specification, *args, …)
Submits work to the thread pool.
Returns true if this executor is in an irrecoverable error state.
Indicates whether worker error management is supported by this executor.
Returns an exception that indicates why this executor is in an irrecoverable state.
Address to the Hub for monitoring.
Port to the Hub for monitoring.
Path to the run directory.
Specify if scaling is enabled.
Returns the interval, in seconds, at which the status method should be called.
Contains a dictionary mapping task IDs to the corresponding Future objects for all tasks that have been submitted to this executor.