diff --git a/conda/environments/cudf_dev_cuda10.1.yml b/conda/environments/cudf_dev_cuda10.1.yml
index 65b72d53496..1e7fcbdc8ff 100644
--- a/conda/environments/cudf_dev_cuda10.1.yml
+++ b/conda/environments/cudf_dev_cuda10.1.yml
@@ -43,7 +43,7 @@ dependencies:
   - typing_extensions
   - pre_commit
   - dask==2021.3.1
-  - distributed==2021.3.1
+  - distributed>=2.22.0,<=2021.3.1
   - streamz
   - dlpack
   - arrow-cpp=1.0.1
diff --git a/conda/environments/cudf_dev_cuda10.2.yml b/conda/environments/cudf_dev_cuda10.2.yml
index b05bbd89572..105a89bf902 100644
--- a/conda/environments/cudf_dev_cuda10.2.yml
+++ b/conda/environments/cudf_dev_cuda10.2.yml
@@ -43,7 +43,7 @@ dependencies:
   - typing_extensions
   - pre_commit
   - dask==2021.3.1
-  - distributed==2021.3.1
+  - distributed>=2.22.0,<=2021.3.1
   - streamz
   - dlpack
   - arrow-cpp=1.0.1
diff --git a/conda/environments/cudf_dev_cuda11.0.yml b/conda/environments/cudf_dev_cuda11.0.yml
index 7b1438da559..bf0f0d236b1 100644
--- a/conda/environments/cudf_dev_cuda11.0.yml
+++ b/conda/environments/cudf_dev_cuda11.0.yml
@@ -43,7 +43,7 @@ dependencies:
   - typing_extensions
   - pre_commit
   - dask==2021.3.1
-  - distributed==2021.3.1
+  - distributed>=2.22.0,<=2021.3.1
   - streamz
   - dlpack
   - arrow-cpp=1.0.1
diff --git a/conda/environments/cudf_dev_cuda11.1.yml b/conda/environments/cudf_dev_cuda11.1.yml
index 91d180c4fa5..a1169539b4a 100644
--- a/conda/environments/cudf_dev_cuda11.1.yml
+++ b/conda/environments/cudf_dev_cuda11.1.yml
@@ -43,7 +43,7 @@ dependencies:
   - typing_extensions
   - pre_commit
   - dask==2021.3.1
-  - distributed==2021.3.1
+  - distributed>=2.22.0,<=2021.3.1
   - streamz
   - dlpack
   - arrow-cpp=1.0.1
diff --git a/conda/environments/cudf_dev_cuda11.2.yml b/conda/environments/cudf_dev_cuda11.2.yml
index 2c0b89c16a3..0952b4ea338 100644
--- a/conda/environments/cudf_dev_cuda11.2.yml
+++ b/conda/environments/cudf_dev_cuda11.2.yml
@@ -43,7 +43,7 @@ dependencies:
   - typing_extensions
   - pre_commit
   - dask==2021.3.1
-  - distributed==2021.3.1
+  - distributed>=2.22.0,<=2021.3.1
   - streamz
   - dlpack
   - arrow-cpp=1.0.1
diff --git a/conda/recipes/custreamz/meta.yaml b/conda/recipes/custreamz/meta.yaml
index ffda6d0c3c6..4b763813001 100644
--- a/conda/recipes/custreamz/meta.yaml
+++ b/conda/recipes/custreamz/meta.yaml
@@ -29,7 +29,7 @@ requirements:
     - streamz 
     - cudf {{ version }}
     - dask >=2.22.0
-    - distributed >=2.22.0
+    - distributed >=2.22.0,<=2021.3.1
     - python-confluent-kafka
     - cudf_kafka {{ version }}
 
diff --git a/conda/recipes/dask-cudf/meta.yaml b/conda/recipes/dask-cudf/meta.yaml
index 3711509056a..38bcfd469b9 100644
--- a/conda/recipes/dask-cudf/meta.yaml
+++ b/conda/recipes/dask-cudf/meta.yaml
@@ -24,12 +24,12 @@ requirements:
     - python
     - cudf {{ version }}
     - dask==2021.3.1
-    - distributed >=2.22.0
+    - distributed >=2.22.0,<=2021.3.1
   run:
     - python
     - cudf {{ version }}
     - dask==2021.3.1
-    - distributed >=2.22.0
+    - distributed >=2.22.0,<=2021.3.1
   
 test:
   requires:
diff --git a/python/custreamz/dev_requirements.txt b/python/custreamz/dev_requirements.txt
index 21c737e6e0f..61b1b8cd7a1 100644
--- a/python/custreamz/dev_requirements.txt
+++ b/python/custreamz/dev_requirements.txt
@@ -4,7 +4,7 @@ flake8==3.8.3
 black==19.10b0
 isort==5.0.7
 dask==2021.3.1
-distributed==2021.3.1
+distributed>=2.22.0,<=2021.3.1
 streamz
 python-confluent-kafka
 pytest
diff --git a/python/dask_cudf/dev_requirements.txt b/python/dask_cudf/dev_requirements.txt
index 625fe26837f..b19501845d1 100644
--- a/python/dask_cudf/dev_requirements.txt
+++ b/python/dask_cudf/dev_requirements.txt
@@ -1,7 +1,7 @@
 # Copyright (c) 2021, NVIDIA CORPORATION.
 
 dask==2021.3.1
-distributed==2021.3.1
+distributed>=2.22.0,<=2021.3.1
 fsspec>=0.6.0
 numba>=0.49.0,!=0.51.0
 numpy
diff --git a/python/dask_cudf/setup.py b/python/dask_cudf/setup.py
index 6465e12b125..caf9bb6bbb0 100644
--- a/python/dask_cudf/setup.py
+++ b/python/dask_cudf/setup.py
@@ -11,7 +11,7 @@
 install_requires = [
     "cudf",
     "dask==2021.3.1",
-    "distributed==2021.3.1",
+    "distributed>=2.22.0,<=2021.3.1",
     "fsspec>=0.6.0",
     "numpy",
     "pandas>=1.0,<1.3.0dev0",
@@ -24,7 +24,7 @@
         "pytest",
         "numba>=0.49.0,!=0.51.0",
         "dask==2021.3.1",
-        "distributed>2.22.0,<=2021.3.1",
+        "distributed>=2.22.0,<=2021.3.1",
     ]
 }