Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.

Prefect Community

hi folks,
what ist the actual equivalent to this?: flow.environment = DaskKubernetesEnvironment()

This should help a lot: <https://docs.prefect.io/orchestration/flow_config/upgrade.html#daskkubernetesenvironment>

image.png

thanks a lot:)
```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: