parsl.dataflow.job_status_poller.JobStatusPoller

class parsl.dataflow.job_status_poller.JobStatusPoller(dfk: DataFlowKernel)

__init__(dfk: DataFlowKernel)

Initialize the Timer object. We start the timer thread here

KWargs:

• interval (int) : number of seconds between callback events

• name (str) : a base name to use when naming the started thread

Methods

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

add_executors(executors: Sequence[ParslExecutor]) → None

poll()