Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat(bootstrapMCPs): follow default globals #520

Merged
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion charts/datahub/Chart.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ description: A Helm chart for DataHub
type: application
# This is the chart version. This version number should be incremented each time you make changes
# to the chart and its templates, including the app version.
version: 0.4.35
version: 0.4.36
# This is the version number of the application being deployed. This version number should be
# incremented each time you make changes to the application.
appVersion: 0.14.1
Expand Down
20 changes: 14 additions & 6 deletions charts/datahub/templates/datahub-upgrade/_upgrade.tpl
Original file line number Diff line number Diff line change
Expand Up @@ -192,19 +192,27 @@ Return the env variables for upgrade jobs
datahubGC cron daily custom scheduling
*/}}
{{- define "datahub.systemUpdate.datahubGC.dailyCronWindow" -}}
{{- if .Values.datahubSystemUpdate.bootstrapMCPs.datahubGC.dailyCronWindow.enabled -}}
{{- if hasKey (index .Values.datahubSystemUpdate.bootstrapMCPs.datahubGC.values "schedule" | default dict) "interval" -}}
schedule:
interval: {{ printf "%d %s * * * " (mod (randNumeric 2) 60) (include "randomHourInRange" (list .Values.datahubSystemUpdate.bootstrapMCPs.datahubGC.dailyCronWindow.startHour .Values.datahubSystemUpdate.bootstrapMCPs.datahubGC.dailyCronWindow.endHour)) }}
interval: {{ .Values.datahubSystemUpdate.bootstrapMCPs.datahubGC.values.schedule.interval | quote }}
{{- else }}
schedule:
interval: {{ .Values.datahubSystemUpdate.bootstrapMCPs.datahubGC.values.schedule.interval | quote }}
interval: {{ printf "%d %s * * * " (mod (randNumeric 2) 60) (include "randomHourInRange" (list .Values.datahubSystemUpdate.bootstrapMCPs.datahubGC.dailyCronWindow.startHour .Values.datahubSystemUpdate.bootstrapMCPs.datahubGC.dailyCronWindow.endHour)) }}
{{- end }}
{{- end -}}

{{/*
datahubGC timezone
timezone
*/}}
{{- define "datahub.systemUpdate.datahubGC.timezone" -}}
{{- define "datahub.bootstrapMCPs.default.schedule.timezone" -}}
schedule:
timezone: {{ .Values.global.datahub.timezone | default .Values.datahubSystemUpdate.bootstrapMCPs.datahubGC.values.schedule.timezone | quote }}
timezone: {{ .Values.global.datahub.timezone | quote }}
{{- end -}}

{{/*
default cli version
*/}}
{{- define "datahub.bootstrapMCPs.default.ingestion.version" -}}
ingestion:
version: {{ .Values.global.datahub.managed_ingestion.defaultCliVersion | quote }}
{{- end -}}
Original file line number Diff line number Diff line change
Expand Up @@ -135,7 +135,14 @@ spec:
value: {{ . | quote }}
{{- end }}
{{- range $k, $v := .Values.datahubSystemUpdate.bootstrapMCPs }}
{{- $result := deepCopy $v.values }}
{{- if ne $k "default" }}
{{- $result := dict }}
{{- range $.Values.datahubSystemUpdate.bootstrapMCPs.default.value_configs }}
{{- $funcOutput := include . $ | fromYaml }}
{{- $result = include "deepMerge" (dict "dst" $result "src" $funcOutput) | fromYaml }}
{{- end }}
{{- $valuesCopy := deepCopy $v.values }}
{{- $result = include "deepMerge" (dict "dst" $result "src" $valuesCopy) | fromYaml }}
{{- range $v.values_generated_configs }}
{{- $funcOutput := include . $ | fromYaml }}
{{- $result = include "deepMerge" (dict "dst" $result "src" $funcOutput) | fromYaml }}
Expand All @@ -147,6 +154,7 @@ spec:
value: '{"version":"{{ $.Chart.Version }}-{{ $.Release.Revision }}"}'
{{- end }}
{{- end }}
{{- end }}
{{- with .Values.datahubSystemUpdate.extraEnvs }}
{{- toYaml . | nindent 12 }}
{{- end }}
Expand Down Expand Up @@ -310,7 +318,14 @@ spec:
value: {{ . | quote }}
{{- end }}
{{- range $k, $v := .Values.datahubSystemUpdate.bootstrapMCPs }}
{{- $result := deepCopy $v.values }}
{{- if ne $k "default" }}
{{- $result := dict }}
{{- range $.Values.datahubSystemUpdate.bootstrapMCPs.default.value_configs }}
{{- $funcOutput := include . $ | fromYaml }}
{{- $result = include "deepMerge" (dict "dst" $result "src" $funcOutput) | fromYaml }}
{{- end }}
{{- $valuesCopy := deepCopy $v.values }}
{{- $result = include "deepMerge" (dict "dst" $result "src" $valuesCopy) | fromYaml }}
{{- range $v.values_generated_configs }}
{{- $funcOutput := include . $ | fromYaml }}
{{- $result = include "deepMerge" (dict "dst" $result "src" $funcOutput) | fromYaml }}
Expand All @@ -322,6 +337,7 @@ spec:
value: '{"version":"{{ $.Chart.Version }}-{{ $.Release.Revision }}"}'
{{- end }}
{{- end }}
{{- end }}
{{- with .Values.datahubSystemUpdate.extraEnvs }}
{{- toYaml . | nindent 12 }}
{{- end }}
Expand Down
19 changes: 11 additions & 8 deletions charts/datahub/values.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -395,30 +395,33 @@ datahubSystemUpdate:
# args: []
# Depends on v0.14.2 or greater
bootstrapMCPs:
default:
value_configs:
- "datahub.bootstrapMCPs.default.ingestion.version"
- "datahub.bootstrapMCPs.default.schedule.timezone"
datahubGC:
# For information about this recipe https://datahubproject.io/docs/0.14.0/generated/ingestion/sources/datahubgc/#install-the-plugin
# Overrides values.schedule.interval below with a jitter window using a generated config
# Generate values.schedule.interval with a jitter window using a generated config
dailyCronWindow:
enabled: true
startHour: 18
endHour: 5
# dynamic overrides, the output to each function is deepMerged with values
values_generated_configs:
- "datahub.systemUpdate.datahubGC.dailyCronWindow"
- "datahub.systemUpdate.datahubGC.timezone"
# Environment variable containing the json value for the template mcp
values_env: DATAHUB_GC_BOOTSTRAP_VALUES
revision_env: DATAHUB_GC_BOOTSTRAP_REVISION
# Base values for the template mcp
values:
ingestion:
name: datahub-gc
# override global.datahub.managed_ingestion.defaultCliVersion
version: "0.14.1.7rc2"
schedule:
# overridden by global.datahub.timezone
timezone: "UTC"
# overridden if dynamic.dailyCronWindow.enable is true
interval: "0 1 * * *"
# schedule:
# # override global.datahub.timezone
# timezone: "UTC"
# # override dailyCronWindow
# interval: "0 1 * * *"
cleanup_expired_tokens: "false"
truncate_indices: "true"
dataprocess_cleanup:
Expand Down
Loading