https://prefect.io logo
l

Laura Vaida

02/11/2021, 9:39 AM
hi folks, what ist the actual equivalent to this?: flow.environment = DaskKubernetesEnvironment()
l

Laura Vaida

02/11/2021, 9:46 AM
thanks a lot:)
Copy code
flow.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: