From 8c60792530604e0908d6b222814e096ebf83c37f Mon Sep 17 00:00:00 2001 From: Reid Mello <30907815+rjmello@users.noreply.github.com> Date: Thu, 27 Jun 2024 16:56:59 -0400 Subject: [PATCH] Remove `dfk` argument from `JobStatusPoller` init As of Parsl PR https://github.com/Parsl/parsl/pull/3338, the `dfk` argument for `JobStatusPoller` initialization is no longer supported. --- .../globus_compute_endpoint/engines/globus_compute.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/compute_endpoint/globus_compute_endpoint/engines/globus_compute.py b/compute_endpoint/globus_compute_endpoint/engines/globus_compute.py index 2e196990e..f6667edc8 100644 --- a/compute_endpoint/globus_compute_endpoint/engines/globus_compute.py +++ b/compute_endpoint/globus_compute_endpoint/engines/globus_compute.py @@ -225,7 +225,7 @@ def start( self.executor.start() self._status_report_thread.start() # Add executor to poller *after* executor has started - self.job_status_poller = JobStatusPoller(dfk=None, **self._job_status_kwargs) + self.job_status_poller = JobStatusPoller(**self._job_status_kwargs) self.job_status_poller.add_executors([self.executor]) def _submit(