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))

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)