Welke scheduler wordt gebruikt?
In het volgende codeblok: welke van de resultaten, w, x, y en z, worden berekend met parallelle processen?
dask_df is een Dask DataFrame en dask_bag is een Dask bag.
w = dask_df.compute()
client = Client(processes=True)
x = dask_df.compute()
y = dask_df.compute(scheduler='threads')
z = dask_bag.compute()
Deze oefening maakt deel uit van de cursus
Parallel programmeren met Dask in Python
Praktische interactieve oefening
Zet theorie om in actie met een van onze interactieve oefeningen.
Begin met trainen