flytekitplugins.dask.Dask

class flytekitplugins.dask.Dask(scheduler=<factory>, workers=<factory>)

Configuration for the dask task

Parameters:

• scheduler (Scheduler) – Configuration for the scheduler pod. Optional, defaults to Scheduler().

• workers (WorkerGroup) – Configuration for the pods of the default worker group. Optional, defaults to WorkerGroup().

Methods

Attributes

scheduler: Scheduler

workers: WorkerGroup