from dask_kubernetes import KubeCluster
import dask.config
#import dask.distributed

dask.config.set({'kubernetes.name': 'myproject'})
cluster = KubeCluster.from_yaml('/worker-spec.yml')
cluster.scale_up(2)

from dask_kubernetes import KubeCluster
import dask.config
#import dask.distributed

dask.config.set({'kubernetes.name': 'myproject'})
cluster = KubeCluster.from_yaml('/worker-spec.yml')
cluster.scale_up(2)

#import dask.distributed