tag:python-multiprocessing

使用 dask 延迟函数返回列表

我正在尝试使用 dask.delayed 来构建任务图。这在大多数情况下都运行良好，但我经常遇到这样的情况，我有许多延迟对象，它们的方法返回一个对象列表，该列表的长度无法根据我目前掌握的信息轻松计算出来：items = get_collection() # known lengthdef do_work(item):# get_list_of_things returns list of "unk

2017-12-11