From f424ac3dab557fac9b5e2749ae575a3306a62e4d Mon Sep 17 00:00:00 2001 From: Guillaume EB Date: Sun, 2 Oct 2022 22:20:13 +0400 Subject: [PATCH] Prevent worker_extra_args to adds up extra arguments --- dask_jobqueue/core.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/dask_jobqueue/core.py b/dask_jobqueue/core.py index 0ed3dc58..b92dc197 100644 --- a/dask_jobqueue/core.py +++ b/dask_jobqueue/core.py @@ -237,6 +237,10 @@ def __init__( warnings.warn(warn, FutureWarning) if not worker_extra_args: worker_extra_args = extra + if worker_extra_args is not None: + # Copy worker_extra_args in order to not modify the object comming from dask.config + # when we'll assign new args like interface to it. See #589. + worker_extra_args = worker_extra_args.copy() if job_extra is None: job_extra = dask.config.get("jobqueue.%s.job-extra" % self.config_name, [])