fix(core): makes Subflow labels dynamic (again)

Fixes #6203
kestra-io · Nov 29, 2024 · 2887d7a · 2887d7a
1 parent b55ad0a
commit 2887d7a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/core/src/main/java/io/kestra/core/runners/ExecutableUtils.java b/core/src/main/java/io/kestra/core/runners/ExecutableUtils.java
@@ -19,6 +19,8 @@
 import java.time.ZonedDateTime;
 import java.util.*;
 
+import static io.kestra.core.utils.Rethrow.throwConsumer;
+
 @Slf4j
 public final class ExecutableUtils {
 
@@ -88,7 +90,7 @@ public static <T extends Task & ExecutableTask<?>> SubflowExecution<?> subflowEx
 
         List<Label> newLabels = inheritLabels ? new ArrayList<>(currentExecution.getLabels()) : new ArrayList<>(systemLabels(currentExecution));
         if (labels != null) {
-            newLabels.addAll(labels);
+            labels.forEach(throwConsumer(label -> newLabels.add(new Label(runContext.render(label.key()), runContext.render(label.value())))));
         }
 
         Map<String, Object> variables = ImmutableMap.of(