Skip to content

Commit f725803

Browse files
Add check for suitable importable distributed module
1 parent 98a3009 commit f725803

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

cf/__init__.py

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -209,6 +209,18 @@
209209
f"Got {dask.__version__} at {dask.__file__}"
210210
)
211211

212+
try:
213+
import distributed
214+
except ImportError as error1:
215+
raise ImportError(_error0 + str(error1))
216+
else:
217+
_minimum_vn = "2025.5.1"
218+
if Version(distributed.__version__) < Version(_minimum_vn):
219+
raise ValueError(
220+
f"Bad distributed version: cf requires distributed>={_minimum_vn}. "
221+
f"Got {distributed.__version__} at {distributed.__file__}"
222+
)
223+
212224
try:
213225
import scipy
214226
except ImportError as error1:

0 commit comments

Comments
 (0)