Laura Vaida

    Laura Vaida

    1 year ago
    hi folks, what ist the actual equivalent to this?: flow.environment = DaskKubernetesEnvironment()
    Greg Roche

    Greg Roche

    1 year ago
    Laura Vaida

    Laura Vaida

    1 year ago
    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: