Quale scheduler verrà usato?
Nel seguente blocco di codice, quali tra i risultati w, x, y e z verranno calcolati usando processi in parallelo?
dask_df è un Dask DataFrame e dask_bag è un Dask bag.
w = dask_df.compute()
client = Client(processes=True)
x = dask_df.compute()
y = dask_df.compute(scheduler='threads')
z = dask_bag.compute()
Questo esercizio fa parte del corso
Programmazione parallela con Dask in Python
Esercizio pratico interattivo
Passa dalla teoria alla pratica con uno dei nostri esercizi interattivi
Inizia esercizio