НачатьНачать бесплатно

Какой планировщик будет использован?

В приведённом ниже блоке кода какие из результатов — 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

Посмотреть курс

Практическое интерактивное упражнение

Превратите теорию в практику с помощью одного из наших интерактивных упражнений

Начать упражнение