From 879846c92060f93a7a4b9b8e7ae9e637fd4434b6 Mon Sep 17 00:00:00 2001 From: Ben Clifford Date: Mon, 8 Apr 2024 17:55:38 +0000 Subject: [PATCH] Do not duplicate executor polling interval in PollingExecutorFacade This is part of work to move JobStatusPoller facade state into other classes, as part of job handling rearrangements in PR #3293 This value is constant, in both executors and in PollingExecutorFacade. This PR should not change behaviour --- parsl/jobs/job_status_poller.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/parsl/jobs/job_status_poller.py b/parsl/jobs/job_status_poller.py index 7a11e1da72..3850dfa670 100644 --- a/parsl/jobs/job_status_poller.py +++ b/parsl/jobs/job_status_poller.py @@ -19,7 +19,6 @@ class PolledExecutorFacade: def __init__(self, executor: BlockProviderExecutor, dfk: Optional["parsl.dataflow.dflow.DataFlowKernel"] = None): self._executor = executor - self._interval = executor.status_polling_interval self._last_poll_time = 0.0 self._status = {} # type: Dict[str, JobStatus] @@ -36,7 +35,7 @@ def __init__(self, executor: BlockProviderExecutor, dfk: Optional["parsl.dataflo logger.info("Monitoring enabled on job status poller") def _should_poll(self, now: float) -> bool: - return now >= self._last_poll_time + self._interval + return now >= self._last_poll_time + self._executor.status_polling_interval def poll(self, now: float) -> None: if self._should_poll(now):