Skip to content

Commit

Permalink
update checks for airflow executor
Browse files Browse the repository at this point in the history
Reflect new executor type DaskExecutor.
  • Loading branch information
cherusk committed Jan 6, 2024
1 parent 3a057f6 commit 170684c
Showing 1 changed file with 7 additions and 3 deletions.
10 changes: 7 additions & 3 deletions charts/airflow/templates/_helpers/validate-values.tpl
Original file line number Diff line number Diff line change
Expand Up @@ -32,8 +32,8 @@
{{- end }}

{{/* Checks for `airflow.executor` */}}
{{- if not (has .Values.airflow.executor (list "CeleryExecutor" "CeleryKubernetesExecutor" "KubernetesExecutor")) }}
{{ required "The `airflow.executor` must be one of: [CeleryExecutor, CeleryKubernetesExecutor, KubernetesExecutor]!" nil }}
{{- if not (has .Values.airflow.executor (list "CeleryExecutor" "CeleryKubernetesExecutor" "KubernetesExecutor", "DaskExecutor")) }}
{{ required "The `airflow.executor` must be one of: [CeleryExecutor, CeleryKubernetesExecutor, KubernetesExecutor, DaskExecutor]!" nil }}
{{- end }}
{{- if eq .Values.airflow.executor "CeleryExecutor" }}
{{- if not .Values.workers.enabled }}
Expand All @@ -50,6 +50,10 @@
{{ required "If `airflow.executor=KubernetesExecutor`, then all of [`workers.enabled`, `flower.enabled`, `redis.enabled`] should be `false`!" nil }}
{{- end }}
{{- end }}
{{- if eq .Values.airflow.executor "DaskExecutor" }}
{{ required "If `airflow.executor=DaskExecutor`, then `dask.enabled` should be `true`!" nil }}
{{- end }}


{{/* Checks for `airflow.config` */}}
{{- if .Values.airflow.config.AIRFLOW__CORE__EXECUTOR }}
Expand Down Expand Up @@ -220,4 +224,4 @@
{{ required "If `externalRedis.host` is set, then `redis.enabled` should be `false`!" nil }}
{{- end }}
{{- end }}
{{- end }}
{{- end }}

0 comments on commit 170684c

Please sign in to comment.