dask.delayedというタスクがある場合、そのタスクのすべての入力（親）のリストを取得したいと考えています。例えば 、 from dask import delayed
@delayed
def inc(x):
return x + 1
def inc_list(x):
return [inc(n) for n in x]
task = delayed(su
私はdaskを試してみる新しいユーザーです。 Delayedに関数とコードを自動的に変換するためにdelayedを使用したい。しかし、私はdelayed.computeを再帰的コレクションで遅延計算しませんでした... from dask import delayed, base
@delayed
def inc(x):
return x + 1
@delayed
def c
daskからdask.arrayを作成する最も効率的な方法は何ですか？ このシリーズは、500万のリスト300から構成されています。 現在、500個のパーティションに分割されています。 は、現在、私がしようとしています： pt = [delayed(np.array)(y)
for y in
[delayed(list)(x)
for x in series.t