fixes for tags

This commit is contained in:
Andrew Nester 2024-09-06 16:19:04 +02:00
parent f667e127df
commit 9783b958b9
No known key found for this signature in database
GPG Key ID: 12BC628A44B7DA57
2 changed files with 4 additions and 5 deletions

View File

@ -168,8 +168,10 @@ func (m *applyPresets) Apply(ctx context.Context, b *bundle.Bundle) diag.Diagnos
c.CustomTags = make(map[string]string) c.CustomTags = make(map[string]string)
} }
for _, tag := range tags { for _, tag := range tags {
if c.CustomTags[tag.Key] == "" { normalisedKey := b.Tagging.NormalizeKey(tag.Key)
c.CustomTags[tag.Key] = tag.Value normalisedValue := b.Tagging.NormalizeValue(tag.Value)
if c.CustomTags[normalisedKey] == "" {
c.CustomTags[normalisedKey] = normalisedValue
} }
} }
} }

View File

@ -11,9 +11,6 @@ resources:
spark_version: "{{.spark_version}}" spark_version: "{{.spark_version}}"
node_type_id: "{{.node_type_id}}" node_type_id: "{{.node_type_id}}"
num_workers: 2 num_workers: 2
autoscale:
min_workers: 2
max_workers: 6
spark_conf: spark_conf:
"spark.executor.memory": "2g" "spark.executor.memory": "2g"