2.0.0b53

Scheduler

Package: flyteplugins.dask.task

Configuration for the scheduler pod

class Scheduler(
    image: typing.Optional[str],
    resources: typing.Optional[flyte._resources.Resources],
)
Parameter Type Description
image typing.Optional[str] 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).
resources typing.Optional[flyte._resources.Resources] Resources to request for the scheduler pod. Optional, defaults to None.