Cover up the right import error.

apache · Nov 7, 2024 · 99ca8f2 · 99ca8f2
1 parent 7e81181
commit 99ca8f2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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):