diff --git a/mhcflurry/parallelism.py b/mhcflurry/parallelism.py index d22473bb4803485c4cd762f82689ccd41318dc43..9bce9c015a5115aeb1cc1b2950f20752f3d8559b 100644 --- a/mhcflurry/parallelism.py +++ b/mhcflurry/parallelism.py @@ -34,7 +34,7 @@ class ParallelBackend(object): class DaskDistributedParallelBackend(ParallelBackend): def __init__(self, scheduler_ip_and_port, verbose=1): - from dask import distributed + from dask import distributed # pylint: disable=import-error executor = distributed.Executor(scheduler_ip_and_port) ParallelBackend.__init__(self, executor, distributed, verbose=verbose) self.scheduler_ip_and_port = scheduler_ip_and_port