Dask Future имеет статус «отменен», но не был отменен

Question

Я создаю приложение Dask и использую SSH-кластер Dask в качестве кластера. Когда я запускаю задачу в Dask и пытаюсь ее дождаться, это вызывает concurrent.futures._base.CancelledError Ошибка.

Мой код следующий:

      def run_custom_task():
    return "aa"


def main():
    cluster = SSHCluster(hosts=['localhost', 'pi01.local'],
                         connect_options=[{'username': 'abc'}, {'username': 'pi'}],
                         worker_options={
                             "nprocs": 1,
                             "nthreads": 1
                         }, 
                         remote_python="/usr/bin/python3")
    client = Client(cluster)

    res = client.submit(run_custom_task)
    print(res.result())

Я получаю следующую ошибку:

      Traceback (most recent call last):
  File "test.py", line 65, in <module>
    main()
  File "test.py", line 59, in main
    x = res.result()
  File "/home/rohan/.local/lib/python3.8/site-packages/distributed/client.py", line 222, in result
    raise result
concurrent.futures._base.CancelledError: run_custom_task-966de894af6e709f1e8067f6e9ffe68

так что кажется, что будущее этой задачи как-то отменяется.

Заранее спасибо!

Answer 1

На самом деле мне уже удалось решить эту проблему: проблема заключалась в том, что версии dask.distributed и dask были разными (2021.04.0 и 2021.05.0) после установки одной и той же версии эта ошибка была решена.