flytekitplugins.dask.Scheduler#

class flytekitplugins.dask.Scheduler(image=None, requests=None, limits=None)#

Configuration for the scheduler pod

Parameters:

image (str | None) – Custom image to use. If None, will use the same image the task was registered with. Optional, defaults to None. The image must have dask[distributed] installed and should have the same Python environment as the rest of the cluster (job runner pod + worker pods).
requests (Resources | None) – Resources to request for the scheduler pod. If None, the requests passed into the task will be used. Optional, defaults to None.
limits (Resources | None) – Resource limits for the scheduler pod. If None, the limits passed into the task will be used. Optional, defaults to None.

Methods

Attributes