From eaa772436390dffe5611f07d2162988653637c4e Mon Sep 17 00:00:00 2001 From: James Gilles Date: Thu, 28 May 2020 17:01:22 -0400 Subject: [PATCH 1/2] Add threads_per_worker parameter --- dask/templates/dask-worker-deployment.yaml | 2 +- dask/values.yaml | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/dask/templates/dask-worker-deployment.yaml b/dask/templates/dask-worker-deployment.yaml index 82d12d6..4647a73 100644 --- a/dask/templates/dask-worker-deployment.yaml +++ b/dask/templates/dask-worker-deployment.yaml @@ -35,7 +35,7 @@ spec: - {{ template "dask.fullname" . }}-scheduler:{{ .Values.scheduler.servicePort }} {{- if .Values.worker.resources.limits }} - --nthreads - - {{ .Values.worker.resources.limits.cpu | default .Values.worker.default_resources.cpu | quote }} + - {{ .Values.worker.threads_per_worker | default .Values.worker.resources.limits.cpu | default .Values.worker.default_resources.cpu | quote }} - --memory-limit - {{ .Values.worker.resources.limits.memory | default .Values.worker.default_resources.memory | quote }} {{- end }} diff --git a/dask/values.yaml b/dask/values.yaml index bee7b9e..41b324b 100644 --- a/dask/values.yaml +++ b/dask/values.yaml @@ -71,12 +71,14 @@ worker: # cpu: 1 # memory: 3G # nvidia.com/gpu: 1 + tolerations: [] nodeSelector: {} affinity: {} securityContext: {} # serviceAccountName: "" # port: "" + # threads_per_worker: 1 jupyter: name: jupyter From 961e69ae1630aed4613140b28f184f384bbfcc61 Mon Sep 17 00:00:00 2001 From: James Gilles Date: Thu, 28 May 2020 17:40:29 -0400 Subject: [PATCH 2/2] Document threads_per_worker option --- dask/values.yaml | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/dask/values.yaml b/dask/values.yaml index 41b324b..b641a44 100644 --- a/dask/values.yaml +++ b/dask/values.yaml @@ -71,14 +71,15 @@ worker: # cpu: 1 # memory: 3G # nvidia.com/gpu: 1 - tolerations: [] nodeSelector: {} affinity: {} securityContext: {} # serviceAccountName: "" # port: "" - # threads_per_worker: 1 + # this option overrides "--nthreads" on workers, which defaults to resources.limits.cpu / default_resources.limits.cpu + # use it if you need to limit the amount of threads used by multicore workers, or to make workers with non-whole-number cpu limits + # threads_per_worker: 1 jupyter: name: jupyter