Laura Vaida
02/11/2021, 9:39 AMGreg Roche
02/11/2021, 9:40 AMLaura Vaida
02/11/2021, 9:46 AMflow.executor = DaskExecutor(
cluster_class=lambda: KubeCluster(make_pod_spec(image=prefect.context.image)),
adapt_kwargs={"minimum": 5, "maximum": 10},
)
do i need this only when i dont have any cluster yet?
my workloads look like this right now: