Заставить объект Dask Delayed для вычисления всех параметров перед применением функции

Question

Мне действительно нравится использовать Dask.

Есть ли способ заставить объект Delayed потребовать, чтобы все его аргументы были вычислены до применения функции delayed?

простой пример (потребительная случай более интересен с коллекцией):

def inc(x, y): 
    return x + y 

dinc = dask.delayed(inc, pure=True) 

к чему-то вроде

def inc(x, y): 
    if hasattr(x, compute): 
     x = x.compute() 
    if hasattr(y, compute): 
     y = y.compute() 
    return x + y 

dinc = dask.delayed(inc, pure=True) 

Таким образом, функция будет действовать в соответствии с сокращения рисунка. Спасибо!

Answer 1

Dask.delayed автоматически делает это. Любые delayed объекты или коллекции dask (массив, dataframe, bag) будут вычисляться до того, как они войдут в функцию с задержкой.