flytekitplugins.dask.Dask#
- class flytekitplugins.dask.Dask(scheduler=Scheduler(image=None, requests=None, limits=None), workers=WorkerGroup(number_of_workers=1, image=None, requests=None, limits=None))[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 = Scheduler(image=None, requests=None, limits=None)#
- workers: flytekitplugins.dask.task.WorkerGroup = WorkerGroup(number_of_workers=1, image=None, requests=None, limits=None)#