Повторные попытки в dask.compute () неясны - PullRequest
Новая
       22

Повторные попытки в dask.compute () неясны

1 голос
/ 25 сентября 2019

Из документации Number of allowed automatic retries if computing a result fails.

Относится ли "результат" к каждой отдельной задаче или ко всему вызову compute ()?

Если это относится ко всему вызову, как реализоватьповторяет для каждой задачи в dask.delayed?

Кроме того, я не уверен, что повторные попытки работают вообще, как показано в приведенном ниже коде. 

import dask
import random

@dask.delayed
def add(x, y):
    return x + y

@dask.delayed
def divide(sum_i):
    n = random.randint(0, 1)
    result = sum_i / n
    return result

tasks = []
for i in range(3):
    sum_i = add(i, i+1)
    divide_n = divide(sum_i)
    tasks.append(divide_n)

dask.compute(*tasks, retries=1000)

Ожидаемый результат равен (1,3, 5), фактической является ZeroDivisionError.

...