Closed delgadom closed 4 years ago
flake8 rhg_compute_tools tests docs
To create cluster which will spin up workers with custom labels and tolerations:
client, cluster = rhgk.get_cluster( extra_worker_labels={ 'project': 'my-project', 'phase': 'phase2', 'job': 'my-big-distributed-job', }, extra_pod_tolerations=[ { "effect": "NoSchedule", "key": "k8s.dask.org_dedicated", "operator": "Equal", "value": "worker-highcpu", }, { "effect": "NoSchedule", "key": "k8s.dask.org/dedicated", "operator": "Equal", "value": "worker-highcpu", }, ], )
flake8 rhg_compute_tools tests docs
Usage
To create cluster which will spin up workers with custom labels and tolerations: