parsl.jobs.job_status_poller.JobStatusPoller

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

__init__(dfk: DataFlowKernel) → None

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[BlockProviderExecutor]) → None

poll() → None