hi folks, what ist the actual equivalent to this?:...
# prefect-community
l
hi folks, what ist the actual equivalent to this?: flow.environment = DaskKubernetesEnvironment()
l
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: