2.0.0b53

flyteplugins.dask.task

Directory

Classes

Class Description
Dask Configuration for the dask task.
DaskTask Actual Plugin that transforms the local python code for execution within a spark context.
DownloadCodeBundleSchedulerPlugin A Dask plugin to download and set up the code bundle on the scheduler.
DownloadCodeBundleWorkerPlugin A Dask plugin to download and set up the code bundle on each worker.
Scheduler Configuration for the scheduler pod.
WorkerGroup Configuration for a group of dask worker pods.