Я использую dask для обработки файлов построчно. Тем не менее, dask кажется, что ничего не делать. Мой код logi c выглядит следующим образом:
dask
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())
Однако в консоли нет никаких выходов. Почему?
Ваша функция test ничего не возвращает.
test
Возможно, вы хотели сделать что-то вроде
def test(): out = [] for i in range(5): out.append(inc(i)) return out
(обратите внимание, что вы уже пометили inc с delayed, там больше не нужно звонить delayed(inc))
inc
delayed
delayed(inc)