関数を適用する前にDask Delayedオブジェクトにすべてのパラメータを計算させる

Question

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) 

のようなものには。 ありがとう！

Answer 1

自動的にDask.delayedがこれを行います。 delayedオブジェクトまたはdaskコレクション（配列、データフレーム、バッグ）は遅延関数に入る前に計算されます。