Мне очень нравится использовать Dask.
Есть ли способ, которым я могу заставить объект 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)
Таким образом, функция будет действовать в соответствии с шаблоном сокращения. Спасибо!
