[dask] fixed wrong import

parent 6469d19b
Pipeline #46382 passed with stages
in 4 minutes and 50 seconds
......@@ -40,6 +40,8 @@ def dask_get_partition_size(cluster, n_objects, lower_bound=200):
Minimum partition size.
"""
from .sge import SGEMultipleQueuesCluster
if not isinstance(cluster, SGEMultipleQueuesCluster):
return None
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment