diff --git a/sdks/python/apache_beam/runners/dask/dask_runner.py b/sdks/python/apache_beam/runners/dask/dask_runner.py
index 5f7dd83a94d3..0f2317074cea 100644
--- a/sdks/python/apache_beam/runners/dask/dask_runner.py
+++ b/sdks/python/apache_beam/runners/dask/dask_runner.py
@@ -45,7 +45,7 @@
   # https://github.com/pytest-dev/pytest/issues/3216#issuecomment-1502451456
   import dask.distributed as ddist
 except ImportError:
-  distributed = {}
+  ddist = {}
 
 
 class DaskOptions(PipelineOptions):