diff --git a/ci/environment.yml b/ci/environment.yml
index 4febda46..4d589b3c 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:
+      - 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