parsl.dataflow.flow_control.FlowControl

class parsl.dataflow.flow_control.FlowControl(dfk)

This class periodically makes a callback to the JobStatusPoller to give the block scaling strategy a chance to execute.

__init__(dfk)

Initialize the flowcontrol object.

We start the timer thread here

Parameters

dfk (-) – DFK object to track parsl progress

Methods

__init__(dfk)	Initialize the flowcontrol object.
add_executors(executors)
close()	Merge the threads and terminate.
make_callback()	Makes the callback and resets the timer.

add_executors(executors: Sequence[parsl.executors.base.ParslExecutor]) → None