Почему в даске отложено ничего не делать?

Question

Я использую dask для обработки файлов построчно. Тем не менее, dask кажется, что ничего не делать. Мой код logi c выглядит следующим образом:

import dask
from dask import delayed
from time import sleep

@dask.delayed
def inc(x):
    sleep(1)
    print(x)


def test():
    for i in range(5):
        delayed(inc)(i)

dask.compute(test())

Однако в консоли нет никаких выходов. Почему?

Answer 1

Ваша функция test ничего не возвращает.

Возможно, вы хотели сделать что-то вроде

def test():
    out = []
    for i in range(5):
        out.append(inc(i))
    return out

(обратите внимание, что вы уже пометили inc с delayed, там больше не нужно звонить delayed(inc))