flytekitplugins.dask.Dask#
- class flytekitplugins.dask.Dask(scheduler=<factory>, workers=<factory>)[source]#
Configuration for the dask task
- Parameters
scheduler (flytekitplugins.dask.task.Scheduler) – Configuration for the scheduler pod. Optional, defaults to
Scheduler().workers (flytekitplugins.dask.task.WorkerGroup) – Configuration for the pods of the default worker group. Optional, defaults to
WorkerGroup().
- Return type
None
Methods
Attributes
- scheduler: flytekitplugins.dask.task.Scheduler