Проблемы с dask после обновления Anaconda в Windows - PullRequest
Новая
       8

Проблемы с dask после обновления Anaconda в Windows

0 голосов
/ 27 марта 2020

Я правильно работал с Dask.distributed, используя Delayed и Futures в Windows, но у меня сегодня возникают проблемы после обновления моей среды anaconda с помощью следующих команд: 

conda update conda
conda update anaconda
conda update spyder

То, что работало ранее, так это не работает сейчас. Даже следующий простой код не работает: 

from dask.distributed import Client

client = Client(n_workers=4)

from time import sleep

def inc(x):
    sleep(1)
    return x + 1

def add(x, y):
    sleep(1)
    return x + y

from dask import delayed
x = delayed(inc)(1)
y = delayed(inc)(2)
z = delayed(add)(x, y)
z.compute()

Он застревает и не дает решения. Я также пытался увидеть ход выполнения, напечатав что-то в начале в c и добавив функции, но система ничего не печатает. Я прикрепляю фигурку приборной панели на случай, если это поможет 1 . Я также прикрепляю результат client.get_versions. Знаете ли вы, есть ли несовместимость Dask с какими-либо новыми версиями связанных пакетов? Любая подсказка о том, что может происходить? 

client.get_versions(check=True)
    {'scheduler': {'host': (('python', '3.7.3.final.0'),
   ('python-bits', 64),
   ('OS', 'Windows'),
   ('OS-release', '10'),
   ('machine', 'AMD64'),
   ('processor', 'Intel64 Family 6 Model 158 Stepping 13, GenuineIntel'),
   ('byteorder', 'little'),
   ('LC_ALL', 'None'),
   ('LANG', 'None'),
   ('LOCALE', 'None.None')),
  'packages': {'required': (('dask', '2.1.0'),
    ('distributed', '2.1.0'),
    ('msgpack', '1.0.0'),
    ('cloudpickle', '1.3.0'),
    ('tornado', '6.0.4'),
    ('toolz', '0.10.0')),
   'optional': (('numpy', '1.18.1'),
    ('pandas', '1.0.3'),
    ('bokeh', '2.0.0'),
    ('lz4', None),
    ('dask_ml', None),
    ('blosc', None))}},
 'workers': {'tcp://192.168.0.13:56997': {'host': (('python', '3.7.3.final.0'),
    ('python-bits', 64),
    ('OS', 'Windows'),
    ('OS-release', '10'),
    ('machine', 'AMD64'),
    ('processor', 'Intel64 Family 6 Model 158 Stepping 13, GenuineIntel'),
    ('byteorder', 'little'),
    ('LC_ALL', 'None'),
    ('LANG', 'None'),
    ('LOCALE', 'None.None')),
   'packages': {'required': (('dask', '2.1.0'),
     ('distributed', '2.1.0'),
     ('msgpack', '1.0.0'),
     ('cloudpickle', '1.3.0'),
     ('tornado', '6.0.4'),
     ('toolz', '0.10.0')),
    'optional': (('numpy', '1.18.1'),
     ('pandas', '1.0.3'),
     ('bokeh', '2.0.0'),
     ('lz4', None),
     ('dask_ml', None),
     ('blosc', None))}},
  'tcp://192.168.0.13:56998': {'host': (('python', '3.7.3.final.0'),
    ('python-bits', 64),
    ('OS', 'Windows'),
    ('OS-release', '10'),
    ('machine', 'AMD64'),
    ('processor', 'Intel64 Family 6 Model 158 Stepping 13, GenuineIntel'),
    ('byteorder', 'little'),
    ('LC_ALL', 'None'),
    ('LANG', 'None'),
    ('LOCALE', 'None.None')),
   'packages': {'required': (('dask', '2.1.0'),
     ('distributed', '2.1.0'),
     ('msgpack', '1.0.0'),
     ('cloudpickle', '1.3.0'),
     ('tornado', '6.0.4'),
     ('toolz', '0.10.0')),
    'optional': (('numpy', '1.18.1'),
     ('pandas', '1.0.3'),
     ('bokeh', '2.0.0'),
     ('lz4', None),
     ('dask_ml', None),
     ('blosc', None))}},
  'tcp://192.168.0.13:57001': {'host': (('python', '3.7.3.final.0'),
    ('python-bits', 64),
    ('OS', 'Windows'),
    ('OS-release', '10'),
    ('machine', 'AMD64'),
    ('processor', 'Intel64 Family 6 Model 158 Stepping 13, GenuineIntel'),
    ('byteorder', 'little'),
    ('LC_ALL', 'None'),
    ('LANG', 'None'),
    ('LOCALE', 'None.None')),
   'packages': {'required': (('dask', '2.1.0'),
     ('distributed', '2.1.0'),
     ('msgpack', '1.0.0'),
     ('cloudpickle', '1.3.0'),
     ('tornado', '6.0.4'),
     ('toolz', '0.10.0')),
    'optional': (('numpy', '1.18.1'),
     ('pandas', '1.0.3'),
     ('bokeh', '2.0.0'),
     ('lz4', None),
     ('dask_ml', None),
     ('blosc', None))}},
  'tcp://192.168.0.13:57003': {'host': (('python', '3.7.3.final.0'),
    ('python-bits', 64),
    ('OS', 'Windows'),
    ('OS-release', '10'),
    ('machine', 'AMD64'),
    ('processor', 'Intel64 Family 6 Model 158 Stepping 13, GenuineIntel'),
    ('byteorder', 'little'),
    ('LC_ALL', 'None'),
    ('LANG', 'None'),
    ('LOCALE', 'None.None')),
   'packages': {'required': (('dask', '2.1.0'),
     ('distributed', '2.1.0'),
     ('msgpack', '1.0.0'),
     ('cloudpickle', '1.3.0'),
     ('tornado', '6.0.4'),
     ('toolz', '0.10.0')),
    'optional': (('numpy', '1.18.1'),
     ('pandas', '1.0.3'),
     ('bokeh', '2.0.0'),
     ('lz4', None),
     ('dask_ml', None),
     ('blosc', None))}}},
 'client': {'host': [('python', '3.7.3.final.0'),
   ('python-bits', 64),
   ('OS', 'Windows'),
   ('OS-release', '10'),
   ('machine', 'AMD64'),
   ('processor', 'Intel64 Family 6 Model 158 Stepping 13, GenuineIntel'),
   ('byteorder', 'little'),
   ('LC_ALL', 'None'),
   ('LANG', 'None'),
   ('LOCALE', 'None.None')],
  'packages': {'required': [('dask', '2.1.0'),
    ('distributed', '2.1.0'),
    ('msgpack', '1.0.0'),
    ('cloudpickle', '1.3.0'),
    ('tornado', '6.0.4'),
    ('toolz', '0.10.0')],
   'optional': [('numpy', '1.18.1'),
    ('pandas', '1.0.3'),
    ('bokeh', '2.0.0'),
    ('lz4', None),
    ('dask_ml', None),
    ('blosc', None)]}}}

1 Ответ

0 голосов
/ 27 марта 2020

Мне удалось это решить. По какой-то причине Anaconda не устанавливает последнюю версию библиотеки dask. Таким образом, обновление пакета dask до последней версии решило проблему.

...