Какой планировщик будет использован?
В приведённом ниже блоке кода какие из результатов — w, x, y и z — будут вычислены с использованием параллельных процессов?
dask_df — это Dask DataFrame, а dask_bag — это Dask bag.
w = dask_df.compute()
client = Client(processes=True)
x = dask_df.compute()
y = dask_df.compute(scheduler='threads')
z = dask_bag.compute()
Это упражнение является частью курса
Параллельное программирование с Dask на Python
Практическое интерактивное упражнение
Превратите теорию в практику с помощью одного из наших интерактивных упражнений
Начать упражнение