parsl.jobs.job_status_poller.JobStatusPoller

class parsl.jobs.job_status_poller.JobStatusPoller(*, strategy: str | None, max_idletime: float, strategy_period: float | int, monitoring: MonitoringRadio | None = None)

__init__(*, strategy: str | None, max_idletime: float, strategy_period: float | int, monitoring: MonitoringRadio | None = None) → None

Initialize the Timer object. We start the timer thread here

KWargs:

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

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

Methods

__init__(*, strategy, max_idletime, ...[, ...])	Initialize the Timer object.
add_executors(executors)
close([timeout])	Merge the threads and terminate.
make_callback()	Makes the callback and resets the timer.
poll()

add_executors(executors: Sequence[BlockProviderExecutor]) → None

close(timeout: float | None = None) → None

Merge the threads and terminate.

poll() → None