From 0855d9150344b9a2830aa170f15ec3f3754cb38c Mon Sep 17 00:00:00 2001 From: Jacob Tomlinson Date: Fri, 10 Oct 2025 09:28:00 +0100 Subject: [PATCH 1/2] Install distributed from PR 9121 --- ci/environment.yml | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/ci/environment.yml b/ci/environment.yml index 4febda46..d120a11a 100644 --- a/ci/environment.yml +++ b/ci/environment.yml @@ -4,10 +4,12 @@ channels: - nodefaults dependencies: - python=3.10 - - dask - - distributed - flake8 - black - pytest - pytest-asyncio - cryptography + - pip: + - pip install git+https://github.com/dask/dask.git + - pip install git+https://github.com/dask/distributed.git@refs/pull/9121/head + From 6a3278d6c87f23f1516d5432e48a38bf924a9a78 Mon Sep 17 00:00:00 2001 From: Jacob Tomlinson Date: Fri, 10 Oct 2025 09:34:33 +0100 Subject: [PATCH 2/2] Fix install commands --- ci/environment.yml | 4 ++-- dask_jobqueue/core.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/ci/environment.yml b/ci/environment.yml index d120a11a..4d589b3c 100644 --- a/ci/environment.yml +++ b/ci/environment.yml @@ -10,6 +10,6 @@ dependencies: - pytest-asyncio - cryptography - pip: - - pip install git+https://github.com/dask/dask.git - - pip install git+https://github.com/dask/distributed.git@refs/pull/9121/head + - git+https://github.com/dask/dask.git + - git+https://github.com/dask/distributed.git@refs/pull/9121/head diff --git a/dask_jobqueue/core.py b/dask_jobqueue/core.py index f62a5055..a918706f 100644 --- a/dask_jobqueue/core.py +++ b/dask_jobqueue/core.py @@ -663,7 +663,7 @@ def __init__( job_kwargs["interface"] = interface job_kwargs["protocol"] = protocol job_kwargs["security"] = self._get_worker_security(security) - + self.queue = queue if queue is not None: job_kwargs["queue"] = queue