From 9f24637c6403f49b4e51abf5acdf6ca47869f5d4 Mon Sep 17 00:00:00 2001 From: Ben Clifford Date: Tue, 9 Apr 2024 00:13:16 -0500 Subject: [PATCH] Do not duplicate executor polling interval in PollingExecutorFacade (#3321) 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):