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