parsl.jobs.job_status_poller.JobStatusPoller

class parsl.jobs.job_status_poller.JobStatusPoller(*, strategy: str | None, max_idletime: float, strategy_period: float | int)[source]
__init__(*, strategy: str | None, max_idletime: float, strategy_period: float | int) None[source]

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[source]
close(timeout: float | None = None) None[source]

Merge the threads and terminate.

poll() None[source]