chore: version 0.18.11

Even if not needed to be sure we use the correct index.

.github/dependabot.yml

@@ -22,12 +22,21 @@ updates:
       - "dependency-upgrade"
     open-pull-requests-limit: 50
 
-  # Maintain dependencies for Npm modules
+  # Maintain dependencies for NPM modules
   - package-ecosystem: "npm"
     directory: "/ui"
     schedule:
-      # Check for updates to Npm modules every week
       interval: "weekly"
-    labels:
-      - "dependency-upgrade"
+      day: "monday"
+      time: "08:00"
+      timezone: "Europe/Paris"
     open-pull-requests-limit: 50
+    labels: ["dependency-upgrade"]
+    reviewers: ["MilosPaunovic"]
+    ignore:
+      # Ignore updates of version 1.x, as we're using beta of 2.x
+      - dependency-name: "vue-virtual-scroller"
+        versions: ["1.x"]
+      # Ignore major versions greater than 8, as it's still known to be flaky
+      - dependency-name: "eslint"
+        versions: [">8"]

.github/workflows/docker.yml

@@ -109,6 +109,11 @@ jobs:
         run: |
           regctl image copy ${{ format('kestra/kestra:{0}{1}', steps.vars.outputs.tag, matrix.image.name) }} ${{ format('kestra/kestra:latest{0}', matrix.image.name) }}
 
+      - name: Retag latest to latest-full
+        if: ${{ github.event.inputs.retag-latest == 'true' && matrix.image.name == ''}}
+        run: |
+          regctl image copy kestra/kestra:latest kestra/kestra:latest-full
+
   end:
     runs-on: ubuntu-latest
     needs:

.github/workflows/main.yml

@@ -4,6 +4,7 @@ on:
   push:
     branches:
       - develop
+      - releases/*
     tags:
       - v*
   pull_request:
@@ -117,10 +118,12 @@ jobs:
         uses: docker/setup-qemu-action@v3
 
       - name: Set up Docker Buildx
+        if: ${{ github.event.inputs.skip-test == 'false' || github.event.inputs.skip-test == '' }}
         uses: docker/setup-buildx-action@v3
 
       # Docker Build
       - name: Build & Export Docker Image
+        if: ${{ github.event.inputs.skip-test == 'false' || github.event.inputs.skip-test == '' }}
         uses: docker/build-push-action@v6
         with:
           context: .
@@ -275,7 +278,7 @@ jobs:
   release:
     name: Github Release
     runs-on: ubuntu-latest
-    needs: [ check, check-e2e ]
+    needs: build-artifacts
     if: startsWith(github.ref, 'refs/tags/v')
     steps:
       # Download Exec
@@ -367,7 +370,7 @@ jobs:
   maven:
     name: Publish to Maven
     runs-on: ubuntu-latest
-    needs: [check, check-e2e]
+    needs: [check]
     if: github.ref == 'refs/heads/develop' || startsWith(github.ref, 'refs/tags/v')
     steps:
       - uses: actions/checkout@v4

cli/src/main/resources/application.yml

@@ -22,6 +22,7 @@ micronaut:
     idle-timeout: 60m
     netty:
       max-chunk-size: 10MB
+      max-header-size: 32768 # increased from the default of 8k
       responses:
         file:
           cache-seconds: 86400

core/src/main/java/io/kestra/core/docs/AbstractClassDocumentation.java

@@ -2,6 +2,7 @@ package io.kestra.core.docs;
 
 import com.google.common.base.CaseFormat;
 import io.kestra.core.models.tasks.retrys.AbstractRetry;
+import io.kestra.core.models.tasks.runners.TaskRunner;
 import lombok.AllArgsConstructor;
 import lombok.EqualsAndHashCode;
 import lombok.Getter;
@@ -144,6 +145,10 @@ public abstract class AbstractClassDocumentation<T> {
             if (AbstractRetry.class.isAssignableFrom(Class.forName(key))) {
                 return true;
             }
+
+            if (TaskRunner.class.isAssignableFrom(Class.forName(key))) {
+                return true;
+            }
         } catch (ClassNotFoundException ignored) {
             log.debug(ignored.getMessage(), ignored);
         }

core/src/main/java/io/kestra/core/docs/Plugin.java

@@ -37,13 +37,16 @@ public class Plugin {
     public static Plugin of(RegisteredPlugin registeredPlugin, @Nullable String subgroup) {
         Plugin plugin = new Plugin();
         plugin.name = registeredPlugin.name();
+        PluginSubGroup subGroupInfos = null;
         if (subgroup == null) {
             plugin.title = registeredPlugin.title();
         } else {
-            plugin.title = subgroup.substring(subgroup.lastIndexOf('.') + 1);
+            subGroupInfos = registeredPlugin.allClass().stream().filter(c -> c.getName().contains(subgroup)).map(clazz -> clazz.getPackage().getDeclaredAnnotation(PluginSubGroup.class)).toList().getFirst();
+            plugin.title = !subGroupInfos.title().isEmpty() ? subGroupInfos.title() : subgroup.substring(subgroup.lastIndexOf('.') + 1);;
+
         }
         plugin.group = registeredPlugin.group();
-        plugin.description = registeredPlugin.description();
+        plugin.description = subGroupInfos != null && !subGroupInfos.description().isEmpty() ? subGroupInfos.description() : registeredPlugin.description();
         plugin.license = registeredPlugin.license();
         plugin.longDescription = registeredPlugin.longDescription();
         plugin.version = registeredPlugin.version();
@@ -59,7 +62,9 @@ public class Plugin {
                 e.getValue().toString()
             ))
             .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
-        plugin.categories =  registeredPlugin
+        plugin.categories = subGroupInfos != null ?
+            Arrays.stream(subGroupInfos.categories()).toList() :
+            registeredPlugin
             .allClass()
             .stream()
             .map(clazz -> clazz.getPackage().getDeclaredAnnotation(PluginSubGroup.class))

core/src/main/java/io/kestra/core/models/executions/LogEntry.java

@@ -61,14 +61,13 @@ public class LogEntry implements DeletedInterface, TenantInterface {
     @Builder.Default
     boolean deleted = false;
 
-    public static List<String> findLevelsByMin(Level minLevel) {
+    public static List<Level> findLevelsByMin(Level minLevel) {
         if (minLevel == null) {
-            return Arrays.stream(Level.values()).map(Enum::name).toList();
+            return Arrays.asList(Level.values());
         }
 
         return Arrays.stream(Level.values())
             .filter(level -> level.toInt() >= minLevel.toInt())
-            .map(Enum::name)
             .toList();
     }
 

core/src/main/java/io/kestra/core/models/flows/Flow.java

@@ -209,6 +209,7 @@ public class Flow extends AbstractFlow {
     public List<String> allTriggerIds() {
         return this.triggers != null ? this.triggers.stream()
             .map(AbstractTrigger::getId)
+            .filter(id -> id != null) // this can happen when validation a flow under creation
             .collect(Collectors.toList()) : Collections.emptyList();
     }
 

core/src/main/java/io/kestra/core/models/flows/input/MultiselectInput.java

@@ -6,7 +6,6 @@ import io.kestra.core.models.validations.ManualConstraintViolation;
 import io.kestra.core.validations.Regex;
 import io.swagger.v3.oas.annotations.media.Schema;
 import jakarta.validation.ConstraintViolationException;
-import jakarta.validation.constraints.NotNull;
 import lombok.Builder;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
@@ -18,11 +17,19 @@ import java.util.List;
 @Getter
 @NoArgsConstructor
 public class MultiselectInput extends Input<List<String>> implements ItemTypeInterface {
+    @Schema(
+        title = "Deprecated, please use `values` instead."
+    )
+//    @NotNull
+    @Deprecated
+    List<@Regex String> options;
+
     @Schema(
         title = "List of values available."
     )
-    @NotNull
-    List<@Regex String> options;
+    // FIXME: REMOVE `options` in 0.20 and bring back the NotNull
+    // @NotNull
+    List<@Regex String> values;
 
     @Schema(
         title = "Type of the different values available.",
@@ -33,10 +40,21 @@ public class MultiselectInput extends Input<List<String>> implements ItemTypeInt
 
     @Override
     public void validate(List<String> inputs) throws ConstraintViolationException {
+        if (values != null && options != null) {
+            throw ManualConstraintViolation.toConstraintViolationException(
+                "you can't define both `values` and `options`",
+                this,
+                MultiselectInput.class,
+                getId(),
+                ""
+            );
+        }
+
         for(String input : inputs){
-            if (!options.contains(input)) {
+            List<@Regex String> finalValues = this.values != null ? this.values : this.options;
+            if (!finalValues.contains(input)) {
                 throw ManualConstraintViolation.toConstraintViolationException(
-                    "it must match the values `" + options + "`",
+                    "it must match the values `" + finalValues + "`",
                     this,
                     MultiselectInput.class,
                     getId(),

core/src/main/java/io/kestra/core/models/tasks/runners/TaskCommands.java

@@ -40,13 +40,17 @@ public interface TaskCommands {
     TargetOS getTargetOS();
 
     default List<Path> relativeWorkingDirectoryFilesPaths() throws IOException {
+        return this.relativeWorkingDirectoryFilesPaths(false);
+    }
+
+    default List<Path> relativeWorkingDirectoryFilesPaths(boolean includeDirectories) throws IOException {
         Path workingDirectory = this.getWorkingDirectory();
         if (workingDirectory == null) {
             return Collections.emptyList();
         }
 
         try (Stream<Path> walk = Files.walk(workingDirectory)) {
-            Stream<Path> filtered = walk.filter(path -> !Files.isDirectory(path));
+            Stream<Path> filtered = includeDirectories ? walk : walk.filter(path -> !Files.isDirectory(path));
             Path outputDirectory = this.getOutputDirectory();
             if (outputDirectory != null) {
                 filtered = filtered.filter(Predicate.not(path -> path.startsWith(outputDirectory)));

core/src/main/java/io/kestra/core/plugins/DefaultPluginRegistry.java

@@ -18,7 +18,7 @@ import java.util.function.Predicate;
  * @see io.kestra.core.plugins.serdes.PluginDeserializer
  * @see PluginScanner
  */
-public final class DefaultPluginRegistry implements PluginRegistry {
+public class DefaultPluginRegistry implements PluginRegistry {
 
     private static class LazyHolder {
         static final DefaultPluginRegistry INSTANCE = new DefaultPluginRegistry();
@@ -43,7 +43,7 @@ public final class DefaultPluginRegistry implements PluginRegistry {
         return instance;
     }
 
-    private DefaultPluginRegistry() {
+    protected DefaultPluginRegistry() {
     }
 
     private boolean isInitialized() {
@@ -53,7 +53,7 @@ public final class DefaultPluginRegistry implements PluginRegistry {
     /**
      * Initializes the registry by loading all core plugins.
      */
-    private void init() {
+    protected void init() {
         if (initialized.compareAndSet(false, true)) {
             register(scanner.scan());
         }

core/src/main/java/io/kestra/core/repositories/FlowRepositoryInterface.java

@@ -32,7 +32,7 @@ public interface FlowRepositoryInterface {
             execution.getTenantId(),
             execution.getNamespace(),
             execution.getFlowId(),
-            Optional.of(execution.getFlowRevision())
+            Optional.ofNullable(execution.getFlowRevision())
         );
 
         if (find.isEmpty()) {
@@ -50,7 +50,7 @@ public interface FlowRepositoryInterface {
             execution.getTenantId(),
             execution.getNamespace(),
             execution.getFlowId(),
-            Optional.of(execution.getFlowRevision())
+            Optional.ofNullable(execution.getFlowRevision())
         );
 
         if (find.isEmpty()) {

core/src/main/java/io/kestra/core/runners/DefaultRunContext.java

@@ -144,18 +144,16 @@ public class DefaultRunContext extends RunContext {
     @Override
     public DefaultRunContext clone() {
         DefaultRunContext runContext = new DefaultRunContext();
-        runContext.variableRenderer = this.variableRenderer;
-        runContext.applicationContext = this.applicationContext;
-        runContext.storageInterface = this.storageInterface;
-        runContext.storage = this.storage;
         runContext.variables = new HashMap<>(this.variables);
-        runContext.metrics = new ArrayList<>();
-        runContext.meterRegistry = this.meterRegistry;
         runContext.workingDir = this.workingDir;
         runContext.logger = this.logger;
+        runContext.metrics = new ArrayList<>();
+        runContext.storage = this.storage;
         runContext.pluginConfiguration = this.pluginConfiguration;
-        runContext.version = version;
-        runContext.isInitialized.set(this.isInitialized.get());
+        if (this.isInitialized.get()) {
+            //Inject all services
+            runContext.init(applicationContext);
+        }
         return runContext;
     }
 

core/src/main/java/io/kestra/core/runners/ExecutorService.java

@@ -358,11 +358,11 @@ public class ExecutorService {
             .withState(executor.getExecution().guessFinalState(flow));
 
         if (flow.getOutputs() != null) {
+            RunContext runContext = runContextFactory.of(executor.getFlow(), executor.getExecution());
             try {
                 Map<String, Object> outputs = flow.getOutputs()
                     .stream()
                     .collect(HashMap::new, (map, entry) -> map.put(entry.getId(), entry.getValue()), Map::putAll);
-                RunContext runContext = runContextFactory.of(executor.getFlow(), executor.getExecution());
                 outputs = runContext.render(outputs);
                 outputs = flowInputOutput.typedOutputs(flow, executor.getExecution(), outputs);
                 newExecution = newExecution.withOutputs(outputs);
@@ -374,8 +374,8 @@ public class ExecutorService {
                     "Failed to render output values",
                     e
                 );
-                newExecution = newExecution
-                    .withState(State.Type.FAILED);
+                runContext.logger().error("Failed to render output values: {}", e.getMessage(), e);
+                newExecution = newExecution.withState(State.Type.FAILED);
             }
         }
 

core/src/main/java/io/kestra/core/runners/FilesService.java

@@ -58,15 +58,19 @@ public abstract class FilesService {
          return inputFiles;
      }
 
-     public static Map<String, URI> outputFiles(RunContext runContext, List<String> outputs) throws Exception {
-         List<Path> allFilesMatching = runContext.workingDir().findAllFilesMatching(outputs);
-         var outputFiles = allFilesMatching.stream()
-             .map(throwFunction(path -> new AbstractMap.SimpleEntry<>(
-                 runContext.workingDir().path().relativize(path).toString(),
-                 runContext.storage().putFile(path.toFile(), resolveUniqueNameForFile(path))
-             )))
-             .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
-         runContext.logger().info("Captured {} output(s).", allFilesMatching.size());
+    public static Map<String, URI> outputFiles(RunContext runContext, List<String> outputs) throws Exception {
+        List<String> renderedOutputs = outputs != null ? runContext.render(outputs) : null;
+        List<Path> allFilesMatching = runContext.workingDir().findAllFilesMatching(renderedOutputs);
+        var outputFiles = allFilesMatching.stream()
+            .map(throwFunction(path -> new AbstractMap.SimpleEntry<>(
+                runContext.workingDir().path().relativize(path).toString(),
+                runContext.storage().putFile(path.toFile(), resolveUniqueNameForFile(path))
+            )))
+            .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
+
+        if (runContext.logger().isTraceEnabled()) {
+            runContext.logger().trace("Captured {} output(s).", allFilesMatching.size());
+        }
 
         return outputFiles;
     }

core/src/main/java/io/kestra/core/runners/FlowExecutorInterface.java

@@ -42,6 +42,10 @@ public interface FlowExecutorInterface {
      * WARNING: this method will NOT check if the namespace is allowed, so it should not be used inside a task.
      */
     default Optional<Flow> findByExecution(Execution execution) {
+        if (execution.getFlowRevision() == null) {
+            return Optional.empty();
+        }
+
         return this.findById(
             execution.getTenantId(),
             execution.getNamespace(),

core/src/main/java/io/kestra/core/runners/FlowInputOutput.java

@@ -290,10 +290,16 @@ public class FlowInputOutput {
                     }
                 }
                 case ARRAY, MULTISELECT -> {
+                    List<?> asList;
+                    if (current instanceof List<?> list) {
+                        asList = list;
+                    } else {
+                        asList = JacksonMapper.toList(((String) current));
+                    }
+
                     if (elementType != null) {
                         // recursively parse the elements only once
-                        yield JacksonMapper.toList(((String) current))
-                            .stream()
+                        yield asList.stream()
                             .map(throwFunction(element -> {
                                 try {
                                     return parseType(execution, elementType, id, null, element);
@@ -303,7 +309,7 @@ public class FlowInputOutput {
                             }))
                             .toList();
                     } else {
-                        yield JacksonMapper.toList(((String) current));
+                        yield asList;
                     }
                 }
             };

core/src/main/java/io/kestra/core/runners/RunVariables.java

@@ -274,9 +274,10 @@ public final class RunVariables {
             // adds any additional variables
             if (variables != null) {
                 builder.putAll(variables);
-                if (logger != null && !variables.containsKey(RunVariables.SECRET_CONSUMER_VARIABLE_NAME)) {
-                    builder.put(RunVariables.SECRET_CONSUMER_VARIABLE_NAME, (Consumer<String>) logger::usedSecret);
-                }
+            }
+
+            if (logger != null && (variables == null || !variables.containsKey(RunVariables.SECRET_CONSUMER_VARIABLE_NAME))) {
+                builder.put(RunVariables.SECRET_CONSUMER_VARIABLE_NAME, (Consumer<String>) logger::usedSecret);
             }
 
             return builder.build();

core/src/main/java/io/kestra/core/runners/pebble/Extension.java

@@ -61,6 +61,7 @@ public class Extension extends AbstractExtension {
         return operators;
     }
 
+    @SuppressWarnings("deprecation")
     @Override
     public Map<String, Filter> getFilters() {
         Map<String, Filter> filters = new HashMap<>();
@@ -104,6 +105,7 @@ public class Extension extends AbstractExtension {
         return tests;
     }
 
+    @SuppressWarnings("deprecation")
     @Override
     public Map<String, Function> getFunctions() {
         Map<String, Function> functions = new HashMap<>();

core/src/main/java/io/kestra/core/runners/pebble/filters/JsonFilter.java

@@ -10,11 +10,8 @@ import java.util.Map;
 @Slf4j
 @Deprecated
 public class JsonFilter extends ToJsonFilter {
-
     @Override
     public Object apply(Object input, Map<String, Object> args, PebbleTemplate self, EvaluationContext context, int lineNumber) throws PebbleException {
-        log.warn("The 'json' filter is deprecated, please use 'toJson' instead");
-
         return super.apply(input, args, self, context, lineNumber);
     }
 }

core/src/main/java/io/kestra/core/runners/pebble/functions/JsonFunction.java

@@ -9,11 +9,8 @@ import java.util.Map;
 @Slf4j
 @Deprecated
 public class JsonFunction extends FromJsonFunction {
-
     @Override
     public Object execute(Map<String, Object> args, PebbleTemplate self, EvaluationContext context, int lineNumber) {
-        log.warn("The 'json' function is deprecated, please use 'fromJson' instead");
-
         return super.execute(args, self, context, lineNumber);
     }
 }

core/src/main/java/io/kestra/core/schedulers/AbstractScheduler.java

@@ -518,7 +518,7 @@ public abstract class AbstractScheduler implements Scheduler, Service {
                             var trigger = f.getTriggerContext().toBuilder().nextExecutionDate(nextExecutionDate).build().checkBackfill();
                             this.triggerState.save(trigger, scheduleContext);
                         }
-                    } catch (InternalException ie) {
+                    } catch (Exception ie) {
                         // validate schedule condition can fail to render variables
                         // in this case, we send a failed execution so the trigger is not evaluated each second.
                         logger.error("Unable to evaluate the trigger '{}'", f.getAbstractTrigger().getId(), ie);
@@ -527,6 +527,7 @@ public abstract class AbstractScheduler implements Scheduler, Service {
                             .tenantId(f.getTriggerContext().getTenantId())
                             .namespace(f.getTriggerContext().getNamespace())
                             .flowId(f.getTriggerContext().getFlowId())
+                            .flowRevision(f.getFlow().getRevision())
                             .labels(f.getFlow().getLabels())
                             .state(new State().withState(State.Type.FAILED))
                             .build();

core/src/main/java/io/kestra/core/services/PluginDefaultService.java

@@ -66,6 +66,10 @@ public class PluginDefaultService {
     protected List<PluginDefault> mergeAllDefaults(Flow flow) {
         List<PluginDefault> list = new ArrayList<>();
 
+        if (flow.getPluginDefaults() != null) {
+            list.addAll(flow.getPluginDefaults());
+        }
+
         if (taskGlobalDefault != null && taskGlobalDefault.getDefaults() != null) {
             if (warnOnce.compareAndSet(false, true)) {
                 log.warn("Global Task Defaults are deprecated, please use Global Plugin Defaults instead via the 'kestra.plugins.defaults' property.");
@@ -77,10 +81,6 @@ public class PluginDefaultService {
             list.addAll(pluginGlobalDefault.getDefaults());
         }
 
-        if (flow.getPluginDefaults() != null) {
-            list.addAll(flow.getPluginDefaults());
-        }
-
         return list;
     }
 

core/src/main/java/io/kestra/core/storages/InternalNamespace.java

@@ -84,7 +84,7 @@ public class InternalNamespace implements Namespace {
      **/
     @Override
     public List<NamespaceFile> all(final String prefix, final boolean includeDirectories) throws IOException {
-        URI namespacePrefix = URI.create(NamespaceFile.of(namespace, Optional.ofNullable(prefix).map(Path::of).orElse(null)).storagePath() + "/");
+        URI namespacePrefix = URI.create(NamespaceFile.of(namespace, Optional.ofNullable(prefix).map(Path::of).orElse(null)).storagePath().toString().replace("\\","/") + "/");
         return storage.allByPrefix(tenant, namespacePrefix, includeDirectories)
             .stream()
             .map(uri -> new NamespaceFile(relativize(uri), uri, namespace))

core/src/main/java/io/kestra/plugin/core/flow/ForEachItem.java

@@ -561,6 +561,11 @@ public class ForEachItem extends Task implements FlowableTask<VoidOutput>, Child
             // get the list of splits from the outputs of the split task
             String taskId = this.id.substring(0, this.id.lastIndexOf('_')) + ForEachItemExecutable.SUFFIX;
             var taskOutput = extractOutput(runContext, taskId);
+            if (taskOutput == null) {
+                // there were no subflow executions
+                return null;
+            }
+
             Integer iterations = (Integer) taskOutput.get(ExecutableUtils.TASK_VARIABLE_NUMBER_OF_BATCHES);
             String subflowOutputsBaseUri = (String) taskOutput.get(ExecutableUtils.TASK_VARIABLE_SUBFLOW_OUTPUTS_BASE_URI);
 

core/src/main/java/io/kestra/plugin/core/flow/If.java

@@ -18,6 +18,7 @@ import io.kestra.core.models.tasks.VoidOutput;
 import io.kestra.core.runners.FlowableUtils;
 import io.kestra.core.runners.RunContext;
 import io.kestra.core.utils.GraphUtils;
+import io.kestra.core.utils.ListUtils;
 import io.kestra.core.utils.TruthUtils;
 import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.EqualsAndHashCode;
@@ -158,7 +159,7 @@ public class If extends Task implements FlowableTask<VoidOutput> {
     @Override
     public Optional<State.Type> resolveState(RunContext runContext, Execution execution, TaskRun parentTaskRun) throws IllegalVariableEvaluationException {
         List<ResolvedTask> childTask = this.childTasks(runContext, parentTaskRun);
-        if (childTask == null) {
+        if (ListUtils.isEmpty(childTask)) {
             // no next task to run, we guess the state from the parent task
             return Optional.of(execution.guessFinalState(null, parentTaskRun, this.isAllowFailure()));
         }

core/src/main/java/io/kestra/plugin/core/flow/WaitFor.java

@@ -159,7 +159,9 @@ public class WaitFor extends Task implements FlowableTask<WaitFor.Output> {
             return false;
         }
 
-        Integer iterationCount = (Integer) parentTaskRun.getOutputs().get("iterationCount");
+        Integer iterationCount = Optional.ofNullable(parentTaskRun.getOutputs())
+            .map(outputs -> (Integer) outputs.get("iterationCount"))
+            .orElse(0);
         if (this.checkFrequency.maxIterations != null && iterationCount != null && iterationCount > this.checkFrequency.maxIterations) {
             if (printLog) {logger.warn("Max iterations reached");}
             return true;
@@ -225,7 +227,9 @@ public class WaitFor extends Task implements FlowableTask<WaitFor.Output> {
 
     public WaitFor.Output outputs(TaskRun parentTaskRun) throws IllegalVariableEvaluationException {
         String value = parentTaskRun != null ?
-            parentTaskRun.getOutputs().get("iterationCount").toString() : "0";
+            String.valueOf(Optional.ofNullable(parentTaskRun.getOutputs())
+                .map(outputs -> outputs.get("iterationCount"))
+                .orElse("0")) : "0";
 
         return Output.builder()
             .iterationCount(Integer.parseInt(value) + 1)

core/src/main/java/io/kestra/plugin/core/flow/WorkingDirectory.java

@@ -28,11 +28,7 @@ import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.*;
 import lombok.experimental.SuperBuilder;
 
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.File;
-import java.io.IOException;
-import java.io.InputStream;
+import java.io.*;
 import java.net.URI;
 import java.nio.file.Files;
 import java.nio.file.Path;
@@ -64,14 +60,14 @@ import jakarta.validation.constraints.NotNull;
             full = true,
             title = "Clone a Git repository into the Working Directory and run a Python script in a Docker container.",
             code = """
-                id: gitPython
+                id: git_python
                 namespace: company.team
 
                 tasks:
                   - id: wdir
                     type: io.kestra.plugin.core.flow.WorkingDirectory
                     tasks:
-                      - id: cloneRepository
+                      - id: clone_repository
                         type: io.kestra.plugin.git.Clone
                         url: https://github.com/kestra-io/examples
                         branch: main
@@ -82,100 +78,103 @@ import jakarta.validation.constraints.NotNull;
                           type: io.kestra.plugin.scripts.runner.docker.Docker
                         containerImage: ghcr.io/kestra-io/pydata:latest
                         commands:
-                          - python scripts/etl_script.py"""
+                          - python scripts/etl_script.py
+                """
         ),
         @Example(
             full = true,
             title = "Add input and output files within a Working Directory to use them in a Python script.",
             code = """
-                id: apiJSONtoMongoDB
+                id: api_json_to_mongodb
                 namespace: company.team
 
                 tasks:
-                - id: wdir
-                  type: io.kestra.plugin.core.flow.WorkingDirectory
-                  outputFiles:
-                    - output.json
-                  inputFiles:
-                    query.sql: |
-                      SELECT sum(total) as total, avg(quantity) as avg_quantity
-                      FROM sales;
-                  tasks:
-                    - id: inlineScript
-                      type: io.kestra.plugin.scripts.python.Script
-                      taskRunner:
-                        type: io.kestra.plugin.scripts.runner.docker.Docker
-                      containerImage: python:3.11-slim
-                      beforeCommands:
-                        - pip install requests kestra > /dev/null
-                      warningOnStdErr: false
-                      script: |
-                        import requests
-                        import json
-                        from kestra import Kestra
+                  - id: wdir
+                    type: io.kestra.plugin.core.flow.WorkingDirectory
+                    outputFiles:
+                      - output.json
+                    inputFiles:
+                      query.sql: |
+                        SELECT sum(total) as total, avg(quantity) as avg_quantity
+                        FROM sales;
+                    tasks:
+                      - id: inline_script
+                        type: io.kestra.plugin.scripts.python.Script
+                        taskRunner:
+                          type: io.kestra.plugin.scripts.runner.docker.Docker
+                        containerImage: python:3.11-slim
+                        beforeCommands:
+                          - pip install requests kestra > /dev/null
+                        warningOnStdErr: false
+                        script: |
+                          import requests
+                          import json
+                          from kestra import Kestra
 
-                        with open('query.sql', 'r') as input_file:
-                            sql = input_file.read()
+                          with open('query.sql', 'r') as input_file:
+                              sql = input_file.read()
 
-                        response = requests.get('https://api.github.com')
-                        data = response.json()
+                          response = requests.get('https://api.github.com')
+                          data = response.json()
 
-                        with open('output.json', 'w') as output_file:
-                            json.dump(data, output_file)
+                          with open('output.json', 'w') as output_file:
+                              json.dump(data, output_file)
 
-                        Kestra.outputs({'receivedSQL': sql, 'status': response.status_code})
+                          Kestra.outputs({'receivedSQL': sql, 'status': response.status_code})
 
-                - id: loadToMongoDB
-                  type: io.kestra.plugin.mongodb.Load
-                  connection:
-                    uri: mongodb://host.docker.internal:27017/
-                  database: local
-                  collection: github
-                  from: "{{ outputs.wdir.uris['output.json'] }}"
+                  - id: load_to_mongodb
+                    type: io.kestra.plugin.mongodb.Load
+                    connection:
+                      uri: mongodb://host.docker.internal:27017/
+                    database: local
+                    collection: github
+                    from: "{{ outputs.wdir.uris['output.json'] }}"
             """
         ),
         @Example(
             full = true,
-            code = {
-                "id: working-directory",
-                "namespace: company.team",
-                "",
-                "tasks:",
-                "  - id: working-directory",
-                "    type: io.kestra.plugin.core.flow.WorkingDirectory",
-                "    tasks:",
-                "      - id: first",
-                "        type: io.kestra.plugin.scripts.shell.Commands",
-                "        commands:",
-                "        - 'echo \"{{ taskrun.id }}\" > {{ workingDir }}/stay.txt'",
-                "      - id: second",
-                "        type: io.kestra.plugin.scripts.shell.Commands",
-                "        commands:",
-                "        - |",
-                "          echo '::{\"outputs\": {\"stay\":\"'$(cat {{ workingDir }}/stay.txt)'\"}}::'"
-            }
+            code = """
+                id: working_directory
+                namespace: company.team
+
+                tasks:
+                  - id: working_directory
+                    type: io.kestra.plugin.core.flow.WorkingDirectory
+                    tasks:
+                      - id: first
+                        type: io.kestra.plugin.scripts.shell.Commands
+                        commands:
+                        - 'echo "{{ taskrun.id }}" > {{ workingDir }}/stay.txt'
+                      - id: second
+                        type: io.kestra.plugin.scripts.shell.Commands
+                        commands:
+                        - |
+                          echo '::{"outputs": {"stay":"'$(cat {{ workingDir }}/stay.txt)'"}}::''
+                """
         ),
         @Example(
             full = true,
             title = "A working directory with a cache of the node_modules directory.",
             code = """
-                id: node-with-cache
+                id: node_with_cache
                 namespace: company.team
+
                 tasks:
-                  - id: working-dir
+                  - id: working_dir
                     type: io.kestra.plugin.core.flow.WorkingDirectory
                     cache:
                       patterns:
                         - node_modules/**
                       ttl: PT1H
                     tasks:
-                    - id: script
-                      type: io.kestra.plugin.scripts.node.Script
-                      beforeCommands:
-                        - npm install colors
-                      script: |
-                        const colors = require("colors");
-                        console.log(colors.red("Hello"));"""
+                      - id: script
+                        type: io.kestra.plugin.scripts.node.Script
+                        beforeCommands:
+                          - npm install colors
+                        script: |
+                          const colors = require("colors");
+                          console.log(colors.red("Hello"));
+                """
         )
     },
     aliases = {"io.kestra.core.tasks.flows.WorkingDirectory", "io.kestra.core.tasks.flows.Worker"}
@@ -263,7 +262,7 @@ public class WorkingDirectory extends Sequential implements NamespaceFilesInterf
             }
         }
 
-        if (this.namespaceFiles != null && Boolean.TRUE.equals(this.namespaceFiles.getEnabled())) {
+        if (this.namespaceFiles != null && !Boolean.FALSE.equals(this.namespaceFiles.getEnabled())) {
             runContext.storage()
                 .namespace()
                 .findAllFilesMatching(this.namespaceFiles.getInclude(), this.namespaceFiles.getExclude())
@@ -333,9 +332,9 @@ public class WorkingDirectory extends Sequential implements NamespaceFilesInterf
                     }
 
                     archive.finish();
-                    File archiveFile = File.createTempFile("archive", ".zip");
-                    Files.write(archiveFile.toPath(), bos.toByteArray());
-                    URI uri = runContext.storage().putCacheFile(archiveFile, getId(), taskRun.getValue());
+                    Path archiveFile = runContext.workingDir().createTempFile( ".zip");
+                    Files.write(archiveFile, bos.toByteArray());
+                    URI uri = runContext.storage().putCacheFile(archiveFile.toFile(), getId(), taskRun.getValue());
                     runContext.logger().debug("Caching in {}", uri);
                 }
             } else {

core/src/main/java/io/kestra/plugin/core/log/PurgeLogs.java

@@ -46,7 +46,7 @@ import java.util.List;
                 "- TRACE",
                 "- DEBUG",
                 "- INFO",
-                "- WARNING",
+                "- WARN",
             }
         )
     }

core/src/main/java/io/kestra/plugin/core/trigger/Flow.java

@@ -1,7 +1,11 @@
 package io.kestra.plugin.core.trigger;
 
+import io.kestra.core.exceptions.IllegalVariableEvaluationException;
+import io.kestra.core.models.Label;
 import io.kestra.core.models.annotations.PluginProperty;
 import io.swagger.v3.oas.annotations.media.Schema;
+import java.util.ArrayList;
+import java.util.List;
 import lombok.*;
 import lombok.experimental.SuperBuilder;
 import io.kestra.core.models.annotations.Example;
@@ -91,7 +95,7 @@ public class Flow extends AbstractTrigger implements TriggerOutput<Flow.Output>
             .namespace(flow.getNamespace())
             .flowId(flow.getId())
             .flowRevision(flow.getRevision())
-            .labels(flow.getLabels())
+            .labels(generateLabels(runContext, flow))
             .state(new State())
             .trigger(ExecutionTrigger.of(
                 this,
@@ -128,6 +132,34 @@ public class Flow extends AbstractTrigger implements TriggerOutput<Flow.Output>
         }
     }
 
+    private List<Label> generateLabels(RunContext runContext, io.kestra.core.models.flows.Flow flow) {
+        final List<Label> labels = new ArrayList<>();
+
+        if (flow.getLabels() != null) {
+            labels.addAll(flow.getLabels()); // no need for rendering
+        }
+
+        if (this.getLabels() != null) {
+            for (Label label : this.getLabels()) {
+                final var value = renderLabelValue(runContext, label);
+                if (value != null) {
+                    labels.add(new Label(label.key(), value));
+                }
+            }
+        }
+
+        return labels;
+    }
+
+    private String renderLabelValue(RunContext runContext, Label label) {
+        try {
+            return runContext.render(label.value());
+        } catch (IllegalVariableEvaluationException e) {
+            runContext.logger().warn("Failed to render label '{}', it will be omitted", label.key(), e);
+            return null;
+        }
+    }
+
     @Builder
     @ToString
     @EqualsAndHashCode

core/src/main/java/io/kestra/plugin/core/trigger/Schedule.java

@@ -5,6 +5,7 @@ import com.cronutils.model.definition.CronDefinitionBuilder;
 import com.cronutils.model.time.ExecutionTime;
 import com.cronutils.parser.CronParser;
 import com.google.common.collect.ImmutableMap;
+import io.kestra.core.exceptions.IllegalVariableEvaluationException;
 import io.kestra.core.exceptions.InternalException;
 import io.kestra.core.models.Label;
 import io.kestra.core.models.annotations.Example;
@@ -361,14 +362,13 @@ public class Schedule extends AbstractTrigger implements PollingTriggerInterface
                 // validate schedule condition can fail to render variables
                 // in this case, we return a failed execution so the trigger is not evaluated each second
                 runContext.logger().error("Unable to evaluate the Schedule trigger '{}'", this.getId(), ie);
-                List<Label> labels = generateLabels(conditionContext, backfill);
                 Execution execution = Execution.builder()
                     .id(runContext.getTriggerExecutionId())
                     .tenantId(triggerContext.getTenantId())
                     .namespace(triggerContext.getNamespace())
                     .flowId(triggerContext.getFlowId())
                     .flowRevision(conditionContext.getFlow().getRevision())
-                    .labels(labels)
+                    .labels(generateLabels(runContext, conditionContext, backfill))
                     .state(new State().withState(State.Type.FAILED))
                     .build();
                 return Optional.of(execution);
@@ -402,7 +402,7 @@ public class Schedule extends AbstractTrigger implements PollingTriggerInterface
         } else {
             variables = scheduleDates.toMap();
         }
-        List<Label> labels = generateLabels(conditionContext, backfill);
+        List<Label> labels = generateLabels(runContext, conditionContext, backfill);
 
         ExecutionTrigger executionTrigger = ExecutionTrigger.of(this, variables);
 
@@ -442,19 +442,29 @@ public class Schedule extends AbstractTrigger implements PollingTriggerInterface
         return parser.parse(this.cron);
     }
 
-    private List<Label> generateLabels(ConditionContext conditionContext, Backfill backfill) {
+    private List<Label> generateLabels(RunContext runContext, ConditionContext conditionContext, Backfill backfill) throws IllegalVariableEvaluationException {
         List<Label> labels = new ArrayList<>();
 
         if (conditionContext.getFlow().getLabels() != null) {
-            labels.addAll(conditionContext.getFlow().getLabels());
+            labels.addAll(conditionContext.getFlow().getLabels()); // no need for rendering
         }
 
         if (backfill != null && backfill.getLabels() != null) {
-            labels.addAll(backfill.getLabels());
+            for (Label label : backfill.getLabels()) {
+                final var value = runContext.render(label.value());
+                if (value != null) {
+                    labels.add(new Label(label.key(), value));
+                }
+            }
         }
 
         if (this.getLabels() != null) {
-            labels.addAll(this.getLabels());
+            for (Label label : this.getLabels()) {
+                final var value = runContext.render(label.value());
+                if (value != null) {
+                    labels.add(new Label(label.key(), value));
+                }
+            }
         }
 
         return labels;

core/src/test/java/io/kestra/core/repositories/AbstractFlowRepositoryTest.java

@@ -5,10 +5,8 @@ import com.google.common.collect.ImmutableList;
 import io.kestra.core.Helpers;
 import io.kestra.core.events.CrudEvent;
 import io.kestra.core.events.CrudEventType;
-import io.kestra.core.models.flows.Flow;
-import io.kestra.core.models.flows.FlowWithException;
-import io.kestra.core.models.flows.FlowWithSource;
-import io.kestra.core.models.flows.Type;
+import io.kestra.core.models.executions.Execution;
+import io.kestra.core.models.flows.*;
 import io.kestra.core.models.flows.input.StringInput;
 import io.kestra.core.models.triggers.Trigger;
 import io.kestra.core.queues.QueueFactoryInterface;
@@ -55,6 +53,9 @@ public abstract class AbstractFlowRepositoryTest {
     @Inject
     protected FlowRepositoryInterface flowRepository;
 
+    @Inject
+    protected ExecutionRepositoryInterface executionRepository;
+
     @Inject
     private LocalFlowRepositoryLoader repositoryLoader;
 
@@ -546,6 +547,67 @@ public abstract class AbstractFlowRepositoryTest {
         }
     }
 
+    @Test
+    void findByExecution() {
+        Flow flow = builder()
+            .revision(1)
+            .build();
+        flowRepository.create(flow, flow.generateSource(), pluginDefaultService.injectDefaults(flow));
+        Execution execution = Execution.builder()
+            .id(IdUtils.create())
+            .namespace(flow.getNamespace())
+            .flowId(flow.getId())
+            .flowRevision(flow.getRevision())
+            .state(new State())
+            .build();
+        execution = executionRepository.save(execution);
+
+        try {
+            Flow full = flowRepository.findByExecution(execution);
+            assertThat(full, notNullValue());
+            assertThat(full.getNamespace(), is(flow.getNamespace()));
+            assertThat(full.getId(), is(flow.getId()));
+
+            full = flowRepository.findByExecutionWithoutAcl(execution);
+            assertThat(full, notNullValue());
+            assertThat(full.getNamespace(), is(flow.getNamespace()));
+            assertThat(full.getId(), is(flow.getId()));
+        } finally {
+            deleteFlow(flow);
+            executionRepository.delete(execution);
+        }
+    }
+
+    @Test
+    void findByExecutionNoRevision() {
+        Flow flow = builder()
+            .revision(3)
+            .build();
+        flowRepository.create(flow, flow.generateSource(), pluginDefaultService.injectDefaults(flow));
+        Execution execution = Execution.builder()
+            .id(IdUtils.create())
+            .namespace(flow.getNamespace())
+            .flowId(flow.getId())
+            .state(new State())
+            .build();
+        executionRepository.save(execution);
+
+        try {
+            Flow full = flowRepository.findByExecution(execution);
+            assertThat(full, notNullValue());
+            assertThat(full.getNamespace(), is(flow.getNamespace()));
+            assertThat(full.getId(), is(flow.getId()));
+
+            full = flowRepository.findByExecutionWithoutAcl(execution);
+            assertThat(full, notNullValue());
+            assertThat(full.getNamespace(), is(flow.getNamespace()));
+            assertThat(full.getId(), is(flow.getId()));
+        } finally {
+            deleteFlow(flow);
+            executionRepository.delete(execution);
+        }
+    }
+
     private void deleteFlow(Flow flow) {
         Integer revision = flowRepository.lastRevision(flow.getTenantId(), flow.getNamespace(), flow.getId());
         flowRepository.delete(flow.toBuilder().revision(revision).build());

core/src/test/java/io/kestra/core/repositories/AbstractLogRepositoryTest.java

@@ -149,7 +149,7 @@ public abstract class AbstractLogRepositoryTest {
 
         logRepository.save(log1);
 
-        logRepository.deleteByQuery(null, "io.kestra.unittest", "flowId", null, null, ZonedDateTime.now().plusMinutes(1));
+        logRepository.deleteByQuery(null, "io.kestra.unittest", "flowId", List.of(Level.TRACE, Level.DEBUG, Level.INFO), null, ZonedDateTime.now().plusMinutes(1));
 
         find = logRepository.findByExecutionId(null, log1.getExecutionId(), null, Pageable.from(1, 50));
         assertThat(find.size(), is(0));

core/src/test/java/io/kestra/core/runners/FilesServiceTest.java

@@ -6,6 +6,7 @@ import org.apache.commons.io.FileUtils;
 import org.junit.jupiter.api.Test;
 
 import java.net.URI;
+import java.util.List;
 import java.util.Map;
 
 import static org.hamcrest.MatcherAssert.assertThat;
@@ -49,4 +50,13 @@ class FilesServiceTest {
         Map<String, URI> outputs = FilesService.outputFiles(runContext, files.keySet().stream().toList());
         assertThat(outputs.size(), is(1));
     }
+
+    @Test
+    void renderOutputFiles() throws Exception {
+        RunContext runContext = runContextFactory.of(Map.of("extension", "txt"));
+        Map<String, String> files = FilesService.inputFiles(runContext, Map.of("file.txt", "content"));
+
+        Map<String, URI> outputs = FilesService.outputFiles(runContext, List.of("*.{{extension}}"));
+        assertThat(outputs.size(), is(1));
+    }
 }

core/src/test/java/io/kestra/core/runners/RunVariablesTest.java

@@ -8,12 +8,20 @@ import org.junit.jupiter.api.Test;
 
 import java.util.Map;
 
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.Matchers.is;
+import static org.hamcrest.Matchers.notNullValue;
+
 class RunVariablesTest {
 
     @Test
+    @SuppressWarnings("unchecked")
     void shouldGetEmptyVariables() {
         Map<String, Object> variables = new RunVariables.DefaultBuilder().build(new RunContextLogger());
-        Assertions.assertEquals(Map.of("envs", Map.of(), "globals", Map.of()), variables);
+        assertThat(variables.size(), is(3));
+        assertThat((Map<String, Object>) variables.get("envs"), is(Map.of()));
+        assertThat((Map<String, Object>) variables.get("globals"), is(Map.of()));
+        assertThat(variables.get("addSecretConsumer"), notNullValue());
     }
 
     @Test

core/src/test/java/io/kestra/core/schedulers/SchedulerPollingTriggerTest.java

@@ -169,6 +169,7 @@ public class SchedulerPollingTriggerTest extends AbstractSchedulerTest {
 
             assertThat(queueCount.getCount(), is(0L));
             assertThat(last.get(), notNullValue());
+            assertThat(last.get().getFlowRevision(), notNullValue());
             assertThat(last.get().getState().getCurrent(), is(State.Type.FAILED));
         }
     }

core/src/test/java/io/kestra/core/services/PluginDefaultServiceTest.java

@@ -25,12 +25,16 @@ import lombok.ToString;
 import lombok.experimental.SuperBuilder;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.params.ParameterizedTest;
+import org.junit.jupiter.params.provider.Arguments;
+import org.junit.jupiter.params.provider.MethodSource;
 
 import java.time.Duration;
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
+import java.util.stream.Stream;
 
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.containsInAnyOrder;
@@ -99,6 +103,51 @@ class PluginDefaultServiceTest {
         ), result);
     }
 
+    @ParameterizedTest
+    @MethodSource
+    void flowDefaultsOverrideGlobalDefaults(boolean flowDefaultForced, boolean globalDefaultForced, String fooValue, String barValue, String bazValue) {
+        final DefaultPrecedenceTester task = DefaultPrecedenceTester.builder()
+            .id("test")
+            .type(DefaultPrecedenceTester.class.getName())
+            .propBaz("taskValue")
+            .build();
+
+        final PluginDefault flowDefault = new PluginDefault(DefaultPrecedenceTester.class.getName(), flowDefaultForced, ImmutableMap.of(
+            "propBar", "flowValue",
+            "propBaz", "flowValue"
+        ));
+        final PluginDefault globalDefault = new PluginDefault(DefaultPrecedenceTester.class.getName(), globalDefaultForced, ImmutableMap.of(
+            "propFoo", "globalValue",
+            "propBar", "globalValue",
+            "propBaz", "globalValue"
+        ));
+
+        final Flow flowWithPluginDefault = Flow.builder()
+            .tasks(Collections.singletonList(task))
+            .pluginDefaults(List.of(flowDefault))
+            .build();
+
+        final PluginGlobalDefaultConfiguration pluginGlobalDefaultConfiguration = new PluginGlobalDefaultConfiguration();
+        pluginGlobalDefaultConfiguration.defaults = List.of(globalDefault);
+
+        pluginDefaultService.pluginGlobalDefault = pluginGlobalDefaultConfiguration;
+
+        final Flow injected = pluginDefaultService.injectDefaults(flowWithPluginDefault);
+
+        assertThat(((DefaultPrecedenceTester) injected.getTasks().getFirst()).getPropFoo(), is(fooValue));
+        assertThat(((DefaultPrecedenceTester) injected.getTasks().getFirst()).getPropBar(), is(barValue));
+        assertThat(((DefaultPrecedenceTester) injected.getTasks().getFirst()).getPropBaz(), is(bazValue));
+    }
+
+    private static Stream<Arguments> flowDefaultsOverrideGlobalDefaults() {
+        return Stream.of(
+            Arguments.of(false, false, "globalValue", "flowValue", "taskValue"),
+            Arguments.of(false, true, "globalValue", "globalValue", "globalValue"),
+            Arguments.of(true, false, "globalValue", "flowValue", "flowValue"),
+            Arguments.of(true, true, "globalValue", "flowValue", "flowValue")
+        );
+    }
+
     @Test
     public void injectFlowAndGlobals() {
         DefaultTester task = DefaultTester.builder()
@@ -297,4 +346,23 @@ class PluginDefaultServiceTest {
             private Map<String, String> val;
         }
     }
+
+    @SuperBuilder
+    @ToString
+    @EqualsAndHashCode
+    @Getter
+    @NoArgsConstructor
+    @Plugin(aliases = "io.kestra.core.services.DefaultPrecedenceTesterAlias")
+    public static class DefaultPrecedenceTester extends Task implements RunnableTask<VoidOutput> {
+        private String propFoo;
+
+        private String propBar;
+
+        private String propBaz;
+
+        @Override
+        public VoidOutput run(RunContext runContext) throws Exception {
+            return null;
+        }
+    }
 }

core/src/test/java/io/kestra/plugin/core/flow/FlowOutputTest.java

@@ -5,25 +5,33 @@ import io.kestra.core.models.flows.State;
 import io.kestra.core.runners.AbstractMemoryRunnerTest;
 import org.junit.jupiter.api.Test;
 
+import java.util.List;
 import java.util.concurrent.TimeoutException;
 
 import static org.hamcrest.MatcherAssert.assertThat;
-import static org.hamcrest.Matchers.aMapWithSize;
-import static org.hamcrest.Matchers.is;
-import static org.hamcrest.Matchers.nullValue;
+import static org.hamcrest.Matchers.*;
 
 class FlowOutputTest extends AbstractMemoryRunnerTest {
 
     static final String NAMESPACE = "io.kestra.tests";
 
     @Test
-    void shouldGetSuccessExecutionForFlowFlowWithOutputs() throws TimeoutException {
+    void shouldGetSuccessExecutionForFlowWithOutputs() throws TimeoutException {
         Execution execution = runnerUtils.runOne(null, NAMESPACE, "flow-with-outputs", null, null);
         assertThat(execution.getOutputs(), aMapWithSize(1));
         assertThat(execution.getOutputs().get("key"), is("{\"value\":\"flow-with-outputs\"}"));
         assertThat(execution.getState().getCurrent(), is(State.Type.SUCCESS));
     }
 
+    @Test
+    @SuppressWarnings("unchecked")
+    void shouldGetSuccessExecutionForFlowWithArrayOutputs() throws TimeoutException {
+        Execution execution = runnerUtils.runOne(null, NAMESPACE, "flow-with-array-outputs", null, null);
+        assertThat(execution.getOutputs(), aMapWithSize(1));
+        assertThat((List<String>) execution.getOutputs().get("myout"), hasItems("1rstValue", "2ndValue"));
+        assertThat(execution.getState().getCurrent(), is(State.Type.SUCCESS));
+    }
+
     @Test
     void shouldGetFailExecutionForFlowWithInvalidOutputs() throws TimeoutException {
         Execution execution = runnerUtils.runOne(null, NAMESPACE, "flow-with-outputs-failed", null, null);

core/src/test/java/io/kestra/plugin/core/flow/ForEachItemCaseTest.java

@@ -102,6 +102,21 @@ public class ForEachItemCaseTest {
         assertThat(triggered.get().getTaskRunList(), hasSize(1));
     }
 
+    @SuppressWarnings("unchecked")
+    public void forEachItemEmptyItems() throws TimeoutException, URISyntaxException, IOException {
+        URI file = emptyItems();
+        Map<String, Object> inputs = Map.of("file", file.toString());
+        Execution execution = runnerUtils.runOne(null, TEST_NAMESPACE, "for-each-item", null,
+            (flow, execution1) -> flowIO.typedInputs(flow, execution1, inputs),
+            Duration.ofSeconds(30));
+
+        // assert on the main flow execution
+        assertThat(execution.getTaskRunList(), hasSize(4));
+        assertThat(execution.getState().getCurrent(), is(State.Type.SUCCESS));
+        Map<String, Object> outputs = execution.getTaskRunList().get(2).getOutputs();
+        assertThat(outputs, nullValue());
+    }
+
     @SuppressWarnings("unchecked")
     public void forEachItemNoWait() throws TimeoutException, InterruptedException, URISyntaxException, IOException {
         CountDownLatch countDownLatch = new CountDownLatch(26);
@@ -261,6 +276,16 @@ public class ForEachItemCaseTest {
         );
     }
 
+    private URI emptyItems() throws URISyntaxException, IOException {
+        File tempFile = File.createTempFile("file", ".txt");
+
+        return storageInterface.put(
+            null,
+            new URI("/file/storage/file.txt"),
+            new FileInputStream(tempFile)
+        );
+    }
+
     private List<String> content() {
         return IntStream
             .range(0, 102)

core/src/test/java/io/kestra/plugin/core/trigger/FlowTest.java

@@ -16,6 +16,7 @@ import java.util.Optional;
 
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.hasItem;
+import static org.hamcrest.Matchers.hasSize;
 import static org.hamcrest.Matchers.is;
 
 @KestraTest
@@ -109,4 +110,49 @@ class FlowTest {
         assertThat(evaluate.get().getLabels(), hasItem(new Label("flow-label-1", "flow-label-1")));
         assertThat(evaluate.get().getLabels(), hasItem(new Label("flow-label-2", "flow-label-2")));
     }
+
+    @Test
+    void success_withLabels() {
+        var flow = io.kestra.core.models.flows.Flow.builder()
+            .id("flow-with-flow-trigger")
+            .namespace("io.kestra.unittest")
+            .revision(1)
+            .labels(List.of(
+                new Label("flow-label-1", "flow-label-1"),
+                new Label("flow-label-2", "flow-label-2")
+            ))
+            .tasks(Collections.singletonList(Return.builder()
+                .id("test")
+                .type(Return.class.getName())
+                .format("test")
+                .build()))
+            .build();
+        var execution = Execution.builder()
+            .id(IdUtils.create())
+            .namespace("io.kestra.unittest")
+            .flowId("flow-with-flow-trigger")
+            .flowRevision(1)
+            .state(State.of(State.Type.RUNNING, Collections.emptyList()))
+            .build();
+        var flowTrigger = Flow.builder()
+            .id("flow")
+            .type(Flow.class.getName())
+            .labels(List.of(
+                new Label("trigger-label-1", "trigger-label-1"),
+                new Label("trigger-label-2", "{{ 'trigger-label-2' }}"),
+                new Label("trigger-label-3", "{{ null }}"), // should return an empty string
+                new Label("trigger-label-4", "{{ foobar }}") // should fail
+            ))
+            .build();
+
+        Optional<Execution> evaluate = flowTrigger.evaluate(runContextFactory.of(), flow, execution);
+
+        assertThat(evaluate.isPresent(), is(true));
+        assertThat(evaluate.get().getLabels(), hasSize(5));
+        assertThat(evaluate.get().getLabels(), hasItem(new Label("flow-label-1", "flow-label-1")));
+        assertThat(evaluate.get().getLabels(), hasItem(new Label("flow-label-2", "flow-label-2")));
+        assertThat(evaluate.get().getLabels(), hasItem(new Label("trigger-label-1", "trigger-label-1")));
+        assertThat(evaluate.get().getLabels(), hasItem(new Label("trigger-label-2", "trigger-label-2")));
+        assertThat(evaluate.get().getLabels(), hasItem(new Label("trigger-label-3", "")));
+    }
 }

core/src/test/java/io/kestra/plugin/core/trigger/ScheduleTest.java

@@ -135,6 +135,35 @@ class ScheduleTest {
         assertThat(inputs.get("input2"), is("default"));
     }
 
+    @Test
+    void success_withLabels() throws Exception {
+        var scheduleTrigger = Schedule.builder()
+            .id("schedule")
+            .cron("0 0 1 * *")
+            .labels(List.of(
+                new Label("trigger-label-1", "trigger-label-1"),
+                new Label("trigger-label-2", "{{ 'trigger-label-2' }}"),
+                new Label("trigger-label-3", "{{ null }}")
+            ))
+            .build();
+        var conditionContext = conditionContext(scheduleTrigger);
+        var date = ZonedDateTime.now()
+            .withDayOfMonth(1)
+            .withHour(0)
+            .withMinute(0)
+            .withSecond(0)
+            .truncatedTo(ChronoUnit.SECONDS)
+            .minusMonths(1);
+        var triggerContext = triggerContext(date, scheduleTrigger);
+
+        Optional<Execution> evaluate = scheduleTrigger.evaluate(conditionContext, triggerContext);
+
+        assertThat(evaluate.isPresent(), is(true));
+        assertThat(evaluate.get().getLabels(), hasItem(new Label("trigger-label-1", "trigger-label-1")));
+        assertThat(evaluate.get().getLabels(), hasItem(new Label("trigger-label-2", "trigger-label-2")));
+        assertThat(evaluate.get().getLabels(), hasItem(new Label("trigger-label-3", "")));
+    }
+
     @SuppressWarnings("unchecked")
     @Test
     void everyMinute() throws Exception {

core/src/test/resources/flows/valids/flow-with-array-outputs.yml

@@ -0,0 +1,16 @@
+id: flow-with-array-outputs
+namespace: io.kestra.tests
+
+tasks:
+  - id: return
+    type: io.kestra.plugin.core.output.OutputValues
+    values:
+      one: "1rstValue"
+      two: "2ndValue"
+
+outputs:
+  - id: myout
+    type: ARRAY
+    value:
+      - "{{ outputs.return.values.one }}"
+      - "{{ outputs.return.values.two }}"

gradle.properties

@@ -1,5 +1,5 @@
-version=0.18.0-SNAPSHOT
+version=0.18.11
 
 org.gradle.parallel=true
 org.gradle.caching=true
-org.gradle.priority=low
+org.gradle.priority=low

jdbc-mysql/src/main/java/io/kestra/repository/mysql/MysqlFlowTopologyRepository.java

@@ -2,9 +2,13 @@ package io.kestra.repository.mysql;
 
 import io.kestra.core.models.topologies.FlowTopology;
 import io.kestra.jdbc.repository.AbstractJdbcFlowTopologyRepository;
+import io.kestra.jdbc.repository.AbstractJdbcRepository;
 import jakarta.inject.Inject;
 import jakarta.inject.Named;
 import jakarta.inject.Singleton;
+import org.jooq.DMLQuery;
+import org.jooq.DSLContext;
+import org.jooq.Record;
 
 @Singleton
 @MysqlRepositoryEnabled
@@ -13,4 +17,13 @@ public class MysqlFlowTopologyRepository extends AbstractJdbcFlowTopologyReposit
     public MysqlFlowTopologyRepository(@Named("flowtopologies") MysqlRepository<FlowTopology> repository) {
         super(repository);
     }
+
+    @Override
+    protected DMLQuery<Record> buildMergeStatement(DSLContext context, FlowTopology flowTopology) {
+        return context.insertInto(this.jdbcRepository.getTable())
+            .set(AbstractJdbcRepository.field("key"), this.jdbcRepository.key(flowTopology))
+            .set(this.jdbcRepository.persistFields(flowTopology))
+            .onDuplicateKeyUpdate()
+            .set(this.jdbcRepository.persistFields(flowTopology));
+    }
 }

jdbc-mysql/src/main/java/io/kestra/runner/mysql/MysqlQueue.java

@@ -7,9 +7,17 @@ import org.jooq.*;
 import org.jooq.Record;
 import org.jooq.impl.DSL;
 
+import java.util.ArrayList;
+import java.util.HashSet;
 import java.util.List;
+import java.util.Set;
+import java.util.stream.Collectors;
 
 public class MysqlQueue<T> extends JdbcQueue<T> {
+
+    // TODO - remove once 'queue' table is re-designed
+    private static final MysqlQueueConsumers QUEUE_CONSUMERS = new MysqlQueueConsumers();
+
     public MysqlQueue(Class<T> cls, ApplicationContext applicationContext) {
         super(cls, applicationContext);
     }
@@ -59,7 +67,7 @@ public class MysqlQueue<T> extends JdbcQueue<T> {
             .where(AbstractJdbcRepository.field("type").eq(this.cls.getName()))
             .and(DSL.or(List.of(
                 AbstractJdbcRepository.field("consumers").isNull(),
-                DSL.condition("NOT(FIND_IN_SET(?, consumers) > 0)", queueType)
+                AbstractJdbcRepository.field("consumers").in(QUEUE_CONSUMERS.allForConsumerNotIn(queueType))
             )));
 
         if (consumerGroup != null) {
@@ -101,4 +109,38 @@ public class MysqlQueue<T> extends JdbcQueue<T> {
 
         update.execute();
     }
+
+    private static final class MysqlQueueConsumers {
+
+        private static final Set<String> CONSUMERS;
+
+        static {
+            CONSUMERS = new HashSet<>();
+            String[] elements = {"indexer", "executor", "worker", "scheduler"};
+            List<String> results = new ArrayList<>();
+            // Generate all combinations and their permutations
+            generateCombinations(elements, new boolean[elements.length], new ArrayList<>(), results);
+            CONSUMERS.addAll(results);
+        }
+
+        public Set<String> allForConsumerNotIn(String consumer) {
+            return CONSUMERS.stream().filter(s -> !s.contains(consumer)).collect(Collectors.toSet());
+        }
+
+        private static void generateCombinations(String[] elements, boolean[] used, List<String> current, List<String> results) {
+            if (!current.isEmpty()) {
+                results.add(String.join(",", current));
+            }
+
+            for (int i = 0; i < elements.length; i++) {
+                if (!used[i]) {
+                    used[i] = true;
+                    current.add(elements[i]);
+                    generateCombinations(elements, used, current, results);
+                    current.removeLast();
+                    used[i] = false;
+                }
+            }
+        }
+    }
 }

jdbc-postgres/src/main/java/io/kestra/repository/postgres/PostgresFlowTopologyRepository.java

@@ -2,9 +2,13 @@ package io.kestra.repository.postgres;
 
 import io.kestra.core.models.topologies.FlowTopology;
 import io.kestra.jdbc.repository.AbstractJdbcFlowTopologyRepository;
+import io.kestra.jdbc.repository.AbstractJdbcRepository;
 import jakarta.inject.Inject;
 import jakarta.inject.Named;
 import jakarta.inject.Singleton;
+import org.jooq.DMLQuery;
+import org.jooq.DSLContext;
+import org.jooq.Record;
 
 @Singleton
 @PostgresRepositoryEnabled
@@ -13,4 +17,14 @@ public class PostgresFlowTopologyRepository extends AbstractJdbcFlowTopologyRepo
     public PostgresFlowTopologyRepository(@Named("flowtopologies") PostgresRepository<FlowTopology> repository) {
         super(repository);
     }
+
+    @Override
+    protected DMLQuery<Record> buildMergeStatement(DSLContext context, FlowTopology flowTopology) {
+        return context.insertInto(this.jdbcRepository.getTable())
+            .set(AbstractJdbcRepository.field("key"), this.jdbcRepository.key(flowTopology))
+            .set(this.jdbcRepository.persistFields(flowTopology))
+            .onConflict(AbstractJdbcRepository.field("key"))
+            .doUpdate()
+            .set(this.jdbcRepository.persistFields(flowTopology));
+    }
 }

jdbc-postgres/src/main/java/io/kestra/repository/postgres/PostgresLogRepository.java

@@ -10,6 +10,7 @@ import org.jooq.impl.DSL;
 import org.slf4j.event.Level;
 
 import java.util.Collections;
+import java.util.List;
 import java.util.stream.Collectors;
 
 
@@ -27,10 +28,9 @@ public class PostgresLogRepository extends AbstractJdbcLogRepository {
     }
 
     @Override
-    protected Condition minLevel(Level minLevel) {
+    protected Condition levelsCondition(List<Level> levels) {
         return DSL.condition("level in (" +
-            LogEntry
-                .findLevelsByMin(minLevel)
+            levels
                 .stream()
                 .map(s -> "'" + s + "'::log_level")
                 .collect(Collectors.joining(", ")) +

jdbc-postgres/src/main/java/io/kestra/repository/postgres/PostgresRepository.java

@@ -1,5 +1,6 @@
 package io.kestra.repository.postgres;
 
+import com.google.common.collect.ImmutableMap;
 import io.kestra.core.queues.QueueService;
 import io.kestra.core.repositories.ArrayListTotal;
 import io.kestra.jdbc.JdbcMapper;
@@ -21,6 +22,7 @@ import org.jooq.Result;
 import org.jooq.SelectConditionStep;
 import org.jooq.impl.DSL;
 
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import jakarta.annotation.Nullable;
@@ -52,12 +54,10 @@ public class PostgresRepository<T> extends io.kestra.jdbc.AbstractJdbcRepository
     @SneakyThrows
     @Override
     public Map<Field<Object>, Object> persistFields(T entity) {
-        Map<Field<Object>, Object> fields = super.persistFields(entity);
-
         String json = JdbcMapper.of().writeValueAsString(entity);
-        fields.replace(AbstractJdbcRepository.field("value"), DSL.val(JSONB.valueOf(json)));
-
-        return fields;
+        return new HashMap<>(ImmutableMap
+            .of(io.kestra.jdbc.repository.AbstractJdbcRepository.field("value"), DSL.val(JSONB.valueOf(json)))
+        );
     }
 
     @SneakyThrows

jdbc/src/main/java/io/kestra/jdbc/repository/AbstractJdbcExecutionRepository.java

@@ -59,6 +59,8 @@ import java.util.function.Function;
 import java.util.stream.Collectors;
 
 public abstract class AbstractJdbcExecutionRepository extends AbstractJdbcRepository implements ExecutionRepositoryInterface, JdbcIndexerInterface<Execution> {
+    private static final int FETCH_SIZE = 100;
+
     protected final io.kestra.jdbc.AbstractJdbcRepository<Execution> jdbcRepository;
     private final ApplicationEventPublisher<CrudEvent<Execution>> eventPublisher;
     private final ApplicationContext applicationContext;
@@ -108,10 +110,13 @@ public abstract class AbstractJdbcExecutionRepository extends AbstractJdbcReposi
                         .where(this.defaultFilter(tenantId))
                         .and(field("trigger_execution_id").eq(triggerExecutionId));
 
-                    select.fetch()
-                        .map(this.jdbcRepository::map)
-                        .forEach(emitter::next);
-                    emitter.complete();
+                    // fetchSize will fetch rows 100 by 100 even for databases where the driver loads all in memory
+                    // using a stream will fetch lazily, otherwise all fetches would be done before starting emitting the items
+                    try (var stream = select.fetchSize(FETCH_SIZE).stream()) {
+                        stream.map(this.jdbcRepository::map).forEach(emitter::next);
+                    } finally {
+                        emitter.complete();
+                    }
                 }),
             FluxSink.OverflowStrategy.BUFFER
         );
@@ -213,11 +218,13 @@ public abstract class AbstractJdbcExecutionRepository extends AbstractJdbcReposi
                         deleted
                     );
 
-                    select.fetch()
-                        .map(this.jdbcRepository::map)
-                        .forEach(emitter::next);
-
-                    emitter.complete();
+                    // fetchSize will fetch rows 100 by 100 even for databases where the driver loads all in memory
+                    // using a stream will fetch lazily, otherwise all fetches would be done before starting emitting the items
+                    try (var stream = select.fetchSize(FETCH_SIZE).stream()) {
+                        stream.map(this.jdbcRepository::map).forEach(emitter::next);
+                    } finally {
+                        emitter.complete();
+                    }
                 }),
             FluxSink.OverflowStrategy.BUFFER
         );

jdbc/src/main/java/io/kestra/jdbc/repository/AbstractJdbcFlowTopologyRepository.java

@@ -4,14 +4,13 @@ import io.kestra.core.models.flows.Flow;
 import io.kestra.core.models.topologies.FlowTopology;
 import io.kestra.core.repositories.FlowTopologyRepositoryInterface;
 import io.kestra.jdbc.runner.JdbcIndexerInterface;
-import jakarta.inject.Singleton;
 import org.jooq.*;
+import org.jooq.Record;
 import org.jooq.impl.DSL;
 
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
-import java.util.stream.Collectors;
 
 public abstract class AbstractJdbcFlowTopologyRepository extends AbstractJdbcRepository implements FlowTopologyRepositoryInterface, JdbcIndexerInterface<FlowTopology> {
     protected final io.kestra.jdbc.AbstractJdbcRepository<FlowTopology> jdbcRepository;
@@ -105,10 +104,7 @@ public abstract class AbstractJdbcFlowTopologyRepository extends AbstractJdbcRep
                     context
                         .batch(flowTopologies
                             .stream()
-                            .map(flowTopology -> context.insertInto(this.jdbcRepository.getTable())
-                                .set(AbstractJdbcRepository.field("key"), this.jdbcRepository.key(flowTopology))
-                                .set(this.jdbcRepository.persistFields(flowTopology))
-                            )
+                            .map(flowTopology -> buildMergeStatement(context, flowTopology))
                             .toList()
                         )
                         .execute();
@@ -116,6 +112,17 @@ public abstract class AbstractJdbcFlowTopologyRepository extends AbstractJdbcRep
             });
     }
 
+    protected DMLQuery<Record> buildMergeStatement(DSLContext context, FlowTopology flowTopology) {
+        return context.mergeInto(this.jdbcRepository.getTable())
+            .using(context.selectOne())
+            .on(AbstractJdbcRepository.field("key").eq(this.jdbcRepository.key(flowTopology)))
+            .whenMatchedThenUpdate()
+            .set(this.jdbcRepository.persistFields(flowTopology))
+            .whenNotMatchedThenInsert()
+            .set(AbstractJdbcRepository.field("key"), this.jdbcRepository.key(flowTopology))
+            .set(this.jdbcRepository.persistFields(flowTopology));
+    }
+
     @Override
     public FlowTopology save(FlowTopology flowTopology) {
         this.jdbcRepository.persist(flowTopology);

jdbc/src/main/java/io/kestra/jdbc/repository/AbstractJdbcLogRepository.java

@@ -350,7 +350,10 @@ public abstract class AbstractJdbcLogRepository extends AbstractJdbcRepository i
                 DSLContext context = DSL.using(configuration);
 
                 return context.delete(this.jdbcRepository.getTable())
-                    .where(field("execution_id", String.class).eq(execution.getId()))
+                    // The deleted field is not used, so ti will always be false.
+                    // We add it here to be sure to use the correct index.
+                    .where(field("deleted", Boolean.class).eq(false))
+                    .and(field("execution_id", String.class).eq(execution.getId()))
                     .execute();
             });
     }
@@ -441,7 +444,7 @@ public abstract class AbstractJdbcLogRepository extends AbstractJdbcRepository i
                 }
 
                 if (logLevels != null) {
-                    delete = delete.and(field("level").in(logLevels));
+                    delete = delete.and(levelsCondition(logLevels));
                 }
 
                 return delete.execute();
@@ -493,7 +496,11 @@ public abstract class AbstractJdbcLogRepository extends AbstractJdbcRepository i
             });
     }
 
-    protected Condition minLevel(Level minLevel) {
-        return field("level").in(LogEntry.findLevelsByMin(minLevel));
+    private Condition minLevel(Level minLevel) {
+        return levelsCondition(LogEntry.findLevelsByMin(minLevel));
+    }
+
+    protected Condition levelsCondition(List<Level> levels) {
+        return field("level").in(levels.stream().map(level -> level.name()).toList());
     }
 }

jdbc/src/main/java/io/kestra/jdbc/repository/AbstractJdbcMetricRepository.java

@@ -150,7 +150,10 @@ public abstract class AbstractJdbcMetricRepository extends AbstractJdbcRepositor
                 DSLContext context = DSL.using(configuration);
 
                 return context.delete(this.jdbcRepository.getTable())
-                    .where(field("execution_id", String.class).eq(execution.getId()))
+                    // The deleted field is not used, so ti will always be false.
+                    // We add it here to be sure to use the correct index.
+                    .where(field("deleted", Boolean.class).eq(false))
+                    .and(field("execution_id", String.class).eq(execution.getId()))
                     .execute();
             });
     }
@@ -168,8 +171,7 @@ public abstract class AbstractJdbcMetricRepository extends AbstractJdbcRepositor
             .getDslContextWrapper()
             .transactionResult(configuration -> {
                 DSLContext context = DSL.using(configuration);
-                SelectConditionStep<Record1<Object>> select = DSL
-                    .using(configuration)
+                SelectConditionStep<Record1<Object>> select = context
                     .selectDistinct(field(field))
                     .from(this.jdbcRepository.getTable())
                     .where(this.defaultFilter(tenantId));
@@ -185,8 +187,7 @@ public abstract class AbstractJdbcMetricRepository extends AbstractJdbcRepositor
             .getDslContextWrapper()
             .transactionResult(configuration -> {
                 DSLContext context = DSL.using(configuration);
-                SelectConditionStep<Record1<Object>> select = DSL
-                    .using(configuration)
+                SelectConditionStep<Record1<Object>> select = context
                     .select(field("value"))
                     .from(this.jdbcRepository.getTable())
                     .where(this.defaultFilter(tenantId));

jdbc/src/test/java/io/kestra/jdbc/runner/JdbcRunnerTest.java

@@ -276,6 +276,11 @@ public abstract class JdbcRunnerTest {
         forEachItemCaseTest.forEachItem();
     }
 
+    @Test
+    void forEachItemEmptyItems() throws URISyntaxException, IOException, TimeoutException {
+        forEachItemCaseTest.forEachItemEmptyItems();
+    }
+
     @Test
     void forEachItemNoWait() throws URISyntaxException, IOException, InterruptedException, TimeoutException {
         forEachItemCaseTest.forEachItemNoWait();

script/src/main/java/io/kestra/plugin/scripts/exec/scripts/runners/CommandsWrapper.java

@@ -132,7 +132,7 @@ public class CommandsWrapper implements TaskCommands {
     }
 
     public ScriptOutput run() throws Exception {
-        if (this.namespaceFiles != null && Boolean.TRUE.equals(this.namespaceFiles.getEnabled())) {
+        if (this.namespaceFiles != null && !Boolean.FALSE.equals(this.namespaceFiles.getEnabled())) {
 
             List<NamespaceFile> matchedNamespaceFiles = runContext.storage()
                 .namespace()

script/src/main/java/io/kestra/plugin/scripts/runner/docker/Docker.java

@@ -342,7 +342,7 @@ public class Docker extends TaskRunner {
             CreateContainerResponse exec = container.exec();
             logger.debug("Container created: {}", exec.getId());
 
-            List<Path> relativeWorkingDirectoryFilesPaths = taskCommands.relativeWorkingDirectoryFilesPaths();
+            List<Path> relativeWorkingDirectoryFilesPaths = taskCommands.relativeWorkingDirectoryFilesPaths(true);
             boolean hasFilesToUpload = !ListUtils.isEmpty(relativeWorkingDirectoryFilesPaths);
             boolean hasFilesToDownload = !ListUtils.isEmpty(filesToDownload);
             boolean outputDirectoryEnabled = taskCommands.outputDirectoryEnabled();

tests/src/main/java/io/kestra/core/models/tasks/runners/AbstractTaskRunnerTest.java

@@ -201,7 +201,7 @@ public abstract class AbstractTaskRunnerTest {
         Mockito.when(commands.getEnableOutputDirectory()).thenReturn(true);
         Mockito.when(commands.outputDirectoryEnabled()).thenReturn(true);
         Mockito.when(commands.getTimeout()).thenReturn(null);
-        Mockito.when(commands.relativeWorkingDirectoryFilesPaths()).thenCallRealMethod();
+        Mockito.when(commands.relativeWorkingDirectoryFilesPaths(true)).thenCallRealMethod();
 
         return commands;
     }

ui/.eslintignore

@@ -1,5 +1,2 @@
-public/vscode/
-public/vscode-web/
-
 node/
 node_modules/

ui/index.html

@@ -30,8 +30,8 @@
         <strong>We're sorry but Kestra doesn't work properly without JavaScript enabled. Please enable it to continue.</strong>
     </noscript>
 
-    <div id="loader-wrapper">
-        <div id="loader"></div>
+    <div id="loader-wrapper" data-test-id="loader-wrapper">
+        <div id="loader" data-test-id="loader"></div>
     </div>
 
     <div id="app-container">

ui/package.json

@@ -1,8 +1,9 @@
 {
   "name": "kestra",
-  "version": "0.1.0",
+  "version": "0.18.6",
   "private": true,
-  "packageManager": "npm@9.8.1",
+  "type": "module",
+  "packageManager": "npm@9.9.3",
   "scripts": {
     "dev": "vite --host",
     "build": "vite build --emptyOutDir",
@@ -12,25 +13,25 @@
     "lint": "eslint . --ext .vue,.js,.jsx,.cjs,.mjs --fix"
   },
   "dependencies": {
-    "@kestra-io/ui-libs": "^0.0.53",
+    "@kestra-io/ui-libs": "^0.0.59",
     "@vue-flow/background": "^1.3.0",
     "@vue-flow/controls": "^1.1.2",
-    "@vue-flow/core": "^1.39.1",
+    "@vue-flow/core": "^1.41.1",
     "ansi-to-html": "^0.7.2",
-    "axios": "^1.7.2",
+    "axios": "^1.7.7",
     "bootstrap": "^5.3.3",
     "buffer": "^6.0.3",
-    "chart.js": "^4.4.3",
+    "chart.js": "^4.4.4",
     "chartjs-chart-treemap": "^2.3.1",
-    "core-js": "^3.37.1",
+    "core-js": "^3.38.1",
     "cronstrue": "^2.50.0",
     "dagre": "^0.8.5",
-    "element-plus": "^2.7.8",
+    "element-plus": "^2.8.2",
     "humanize-duration": "^3.32.1",
     "js-yaml": "^4.1.0",
     "lodash": "^4.17.21",
     "markdown-it": "^14.1.0",
-    "markdown-it-anchor": "^9.0.1",
+    "markdown-it-anchor": "^9.2.0",
     "markdown-it-container": "^4.0.0",
     "markdown-it-mark": "^4.0.0",
     "markdown-it-meta": "0.0.1",
@@ -39,51 +40,51 @@
     "moment": "^2.30.1",
     "moment-range": "4.0.2",
     "moment-timezone": "^0.5.45",
-    "node-modules-polyfill": "^0.1.4",
     "nprogress": "^0.2.0",
-    "pdfjs-dist": "^4.5.136",
-    "posthog-js": "^1.150.1",
+    "pdfjs-dist": "^4.6.82",
+    "posthog-js": "^1.160.3",
     "throttle-debounce": "^5.0.2",
-    "vite-plugin-eslint": "^1.8.1",
-    "vue": "^3.4.34",
+    "vue": "^3.5.3",
     "vue-axios": "3.5.2",
     "vue-chartjs": "^5.3.1",
     "vue-gtag": "^2.0.1",
-    "vue-i18n": "^9.13.1",
+    "vue-i18n": "^9.14.0",
     "vue-material-design-icons": "^5.3.0",
-    "vue-router": "^4.4.0",
-    "vue-sidebar-menu": "^5.4.0",
+    "vue-router": "^4.4.3",
+    "vue-sidebar-menu": "^5.4.1",
     "vue-virtual-scroller": "^2.0.0-beta.8",
     "vue3-popper": "^1.5.0",
     "vue3-runtime-template": "^1.0.2",
     "vue3-tour": "github:kestra-io/vue3-tour",
     "vuex": "^4.1.0",
     "xss": "^1.0.15",
-    "yaml": "^2.5.0"
+    "yaml": "^2.5.1"
   },
   "devDependencies": {
+    "@esbuild-plugins/node-modules-polyfill": "^0.2.2",
     "@rushstack/eslint-patch": "^1.10.4",
-    "@shikijs/markdown-it": "^1.6.3",
-    "@typescript-eslint/parser": "^7.17.0",
-    "@vitejs/plugin-vue": "^5.1.1",
+    "@shikijs/markdown-it": "^1.16.2",
+    "@typescript-eslint/parser": "^8.4.0",
+    "@vitejs/plugin-vue": "^5.1.3",
     "@vue/eslint-config-prettier": "^9.0.0",
     "@vue/test-utils": "^2.4.6",
     "decompress": "^4.2.1",
     "eslint": "^8.57.0",
-    "eslint-plugin-vue": "^9.27.0",
-    "jsdom": "^24.1.1",
-    "monaco-editor": "^0.50.0",
+    "eslint-plugin-vue": "^9.28.0",
+    "jsdom": "^25.0.0",
+    "monaco-editor": "^0.51.0",
     "monaco-yaml": "^5.2.2",
     "prettier": "^3.3.3",
     "rollup-plugin-copy": "^3.5.0",
     "rollup-plugin-visualizer": "^5.12.0",
-    "sass": "^1.77.4",
+    "sass": "^1.78.0",
     "typescript": "^5.5.4",
-    "vite": "^5.3.5",
-    "vitest": "^2.0.4"
+    "vite": "^5.4.6",
+    "vite-plugin-eslint": "^1.8.1",
+    "vitest": "^2.0.5"
   },
   "optionalDependencies": {
-    "@rollup/rollup-linux-x64-gnu": "^4.19.0"
+    "@rollup/rollup-linux-x64-gnu": "^4.21.2"
   },
   "overrides": {
     "bootstrap": {

ui/plugins/commit.ts

@@ -0,0 +1,30 @@
+import type {Plugin} from "vite";
+import {execSync} from "child_process";
+
+const getInfo = (formats: string[]): string[] => formats.map(format => execSync(`git log -1 --format=${format}`).toString().trim());
+
+const comment = (message: string, author: string, date: string): string => `
+<!--
+
+    Last Commit: 
+
+    ${message}
+    ----------
+    Author: ${author}
+    Date: ${date}
+
+-->`;
+
+export const commit = (): Plugin => {
+    const [message, author, date] = getInfo(["%s", "%an", "%cd"]);
+
+    return {
+        name: "commit",
+        transformIndexHtml: {
+            order: "pre",
+            handler(html: string): string {
+                return comment(message, author, date) + html;
+            },
+        },
+    };
+};

ui/plugins/details.ts

@@ -1,29 +0,0 @@
-import type {Plugin} from "vite";
-import {execSync} from "child_process";
-
-const comment = (hash: string, date: string): string => {
-    return `
-<!--
-
-    Last Commit: 
-      
-    URL: https://github.com/kestra-io/kestra/commit/${hash}
-    Date: ${date}
-
--->`;
-};
-
-export const details = (): Plugin => {
-    const hash: string = execSync("git rev-parse --short HEAD").toString().trim();
-    const date: string = execSync("git log -1 --format=%cd").toString().trim();
-
-    return {
-        name: "details",
-        transformIndexHtml: {
-            order: "pre",
-            handler(html: string): string {
-                return comment(hash, date) + html;
-            },
-        },
-    };
-};

ui/src/components/EnterpriseTooltip.vue

@@ -68,6 +68,7 @@
         },
         methods: {
             changeVisibility(visible = true) {
+                if (visible) document.querySelector(".ee-tooltip")?.remove();
                 this.visible = visible
             }
         },

ui/src/components/admin/Triggers.vue

@@ -86,6 +86,7 @@
                             :label="$t('id')"
                         />
                         <el-table-column
+                            prop="flowId"
                             sortable="custom"
                             :sort-orders="['ascending', 'descending']"
                             :label="$t('flow')"

ui/src/components/executions/Executions.vue

@@ -61,6 +61,14 @@
                         @update:filter-value="onDataTableValue"
                     />
                 </el-form-item>
+                <el-form-item>
+                    <scope-filter-buttons
+                        :label="$t('executions')"
+                        :value="$route.query.scope"
+                        :system="namespace === 'system'"
+                        @update:model-value="onDataTableValue('scope', $event)"
+                    />
+                </el-form-item>
                 <el-form-item>
                     <label-filter
                         :model-value="$route.query.labels"
@@ -106,6 +114,13 @@
                         />
                     </el-select>
                 </el-form-item>
+                <el-form-item>
+                    <el-switch
+                        :model-value="showChart"
+                        @update:model-value="onShowChartChange"
+                        :active-text="$t('show chart')"
+                    />
+                </el-form-item>
                 <el-form-item>
                     <filters :storage-key="filterStorageKey" />
                 </el-form-item>
@@ -118,7 +133,7 @@
                 </el-form-item>
             </template>
 
-            <template #top v-if="isDisplayedTop">
+            <template #top v-if="showStatChart()">
                 <state-global-chart
                     v-if="daily"
                     class="mb-4"
@@ -410,7 +425,6 @@
     import StatusFilterButtons from "../layout/StatusFilterButtons.vue"
     import StateGlobalChart from "../../components/stats/StateGlobalChart.vue";
     import TriggerAvatar from "../../components/flows/TriggerAvatar.vue";
-    import DateAgo from "../layout/DateAgo.vue";
     import Kicon from "../Kicon.vue"
     import Labels from "../layout/Labels.vue"
     import RestoreUrl from "../../mixins/restoreUrl";
@@ -423,6 +437,7 @@
     import {storageKeys} from "../../utils/constants";
     import LabelInput from "../../components/labels/LabelInput.vue";
     import {ElMessageBox, ElSwitch, ElFormItem, ElAlert, ElCheckbox} from "element-plus";
+    import DateAgo from "../layout/DateAgo.vue";
     import {h, ref} from "vue";
 
     import {filterLabels} from "./utils"
@@ -493,6 +508,7 @@
                 dblClickRouteName: "executions/update",
                 flowTriggerDetails: undefined,
                 recomputeInterval: false,
+                showChart: ["true", null].includes(localStorage.getItem(storageKeys.SHOW_CHART)),
                 optionalColumns: [
                     {
                         label: "start date",
@@ -568,7 +584,6 @@
             }
             this.displayColumns = localStorage.getItem(this.storageKey)?.split(",")
                 || this.optionalColumns.filter(col => col.default).map(col => col.prop);
-
         },
         computed: {
             ...mapState("execution", ["executions", "total"]),
@@ -641,6 +656,17 @@
             displayColumn(column) {
                 return this.hidden ? !this.hidden.includes(column) : this.displayColumns.includes(column);
             },
+            onShowChartChange(value) {
+                this.showChart = value;
+                localStorage.setItem(storageKeys.SHOW_CHART, value);
+
+                if (this.showChart) {
+                    this.loadStats();
+                }
+            },
+            showStatChart() {
+                return this.isDisplayedTop && this.showChart;
+            },
             refresh() {
                 this.recomputeInterval = !this.recomputeInterval;
                 this.load();
@@ -676,19 +702,22 @@
 
                 return _merge(base, queryFilter)
             },
+            loadStats() {
+                this.dailyReady = false;
+
+                this.$store
+                    .dispatch("stat/daily", this.loadQuery({
+                        startDate: this.$moment(this.startDate).toISOString(true),
+                        endDate: this.$moment(this.endDate).toISOString(true)
+                    }, true))
+                    .then(() => {
+                        this.dailyReady = true;
+                    });
+            },
             loadData(callback) {
                 this.refreshDates = !this.refreshDates;
-                if (this.isDisplayedTop) {
-                    this.dailyReady = false;
-
-                    this.$store
-                        .dispatch("stat/daily", this.loadQuery({
-                            startDate: this.$moment(this.startDate).toISOString(true),
-                            endDate: this.$moment(this.endDate).toISOString(true)
-                        }, true))
-                        .then(() => {
-                            this.dailyReady = true;
-                        });
+                if (this.showStatChart()) {
+                    this.loadStats();
                 }
 
                 this.$store.dispatch("execution/findExecutions", this.loadQuery({
@@ -765,7 +794,7 @@
             },
             deleteExecutions() {
                 const includeNonTerminated = ref(false);
-                
+
                 const deleteLogs = ref(true);
                 const deleteMetrics = ref(true);
                 const deleteStorage = ref(true);
@@ -784,7 +813,7 @@
                             "onUpdate:modelValue": (val) => {
                                 includeNonTerminated.value = val
                             },
-                        }),                       
+                        }),
                     ]),
                     h(ElAlert, {
                         title: this.$t("execution-warn-deleting-still-running"),

ui/src/components/executions/Logs.vue

@@ -34,6 +34,7 @@
             </el-form-item>
             <el-form-item>
                 <el-button-group>
+                    <restart :execution="execution" class="ms-0" @follow="forwardEvent('follow', $event)" />
                     <el-button @click="downloadContent()">
                         <kicon :tooltip="$t('download logs')">
                             <download />
@@ -79,6 +80,7 @@
     import State from "../../utils/state";
     import Utils from "../../utils/utils";
     import LogLine from "../logs/LogLine.vue";
+    import Restart from "./Restart.vue";
 
     export default {
         components: {
@@ -88,7 +90,8 @@
             Kicon,
             Download,
             Magnify,
-            Collapse
+            Collapse,
+            Restart
         },
         data() {
             return {

ui/src/components/executions/VarValue.vue

@@ -10,6 +10,13 @@
         </el-button>
     </el-button-group>
 
+    <el-button-group v-else-if="isURI(value)">
+        <a class="el-button el-button--small el-button--primary" :href="value" target="_blank">
+            <OpenInNew />
+            {{ $t('open') }}
+        </a>        
+    </el-button-group>
+
     <span v-else-if="value === null">
         <em>null</em>
     </span>
@@ -20,6 +27,7 @@
 
 <script setup>
     import Download from "vue-material-design-icons/Download.vue";
+    import OpenInNew from "vue-material-design-icons/OpenInNew.vue";
     import FilePreview from "./FilePreview.vue";
 </script>
 
@@ -37,6 +45,14 @@
             isFile(value) {
                 return typeof(value) === "string" && value.startsWith("kestra:///")
             },
+            isURI(value) {
+                try {
+                    new URL(value);
+                    return true;
+                } catch (e) {
+                    return false;
+                }
+            },
             itemUrl(value) {
                 return `${apiUrl(this.$store)}/executions/${this.execution.id}/file?path=${value}`;
             },

ui/src/components/executions/outputs/Wrapper.vue

@@ -17,12 +17,12 @@
                 @expand-change="() => scrollRight()"
             >
                 <template #default="{data}">
-                    <div v-if="data.heading" class="pe-none d-flex fs-5">
+                    <div v-if="data.heading" @click="expandedValue = data.path" class="pe-none d-flex fs-5">
                         <component :is="data.component" class="me-2" />
                         <span>{{ data.label }}</span>
                     </div>
 
-                    <div v-else class="w-100 d-flex justify-content-between">
+                    <div v-else @click="expandedValue = data.path" class="w-100 d-flex justify-content-between">
                         <div class="pe-5 d-flex task">
                             <TaskIcon v-if="data.icon" :icons="allIcons" :cls="icons[data.taskId]" only-icon />
                             <span :class="{'ms-3': data.icon}">{{ data.label }}</span>
@@ -65,6 +65,7 @@
                                 :input="true"
                                 :navbar="false"
                                 :model-value="computedDebugValue"
+                                @confirm="onDebugExpression($event)"
                                 class="w-100"
                             />
 
@@ -91,9 +92,13 @@
                     </el-collapse-item>
                 </el-collapse>
 
-                <el-alert v-if="debugError" type="error" :closable="false">
+                <el-alert v-if="debugError" type="error" :closable="false" class="overflow-auto">
                     <p><strong>{{ debugError }}</strong></p>
-                    <pre class="mb-0">{{ debugStackTrace }}</pre>
+                    <div class="my-2">
+                        <CopyToClipboard :text="debugError" label="Copy Error" class="d-inline-block me-2" />
+                        <CopyToClipboard :text="debugStackTrace" label="Copy Stack Trace" class="d-inline-block" />
+                    </div>
+                    <pre class="mb-0" style="overflow: scroll;">{{ debugStackTrace }}</pre>
                 </el-alert>
 
                 <VarValue :value="selectedValue" :execution="execution" />
@@ -115,15 +120,25 @@
 
     import {apiUrl} from "override/utils/route";
 
+    import CopyToClipboard from "../../layout/CopyToClipboard.vue"
+
     import Editor from "../../inputs/Editor.vue";
     const debugEditor = ref(null);
     const debugExpression = ref("");
-    const computedDebugValue = computed(() => `{{ outputs${selectedTask()?.taskId ? `.${selectedTask().taskId}` : ""} }}`);
+    const computedDebugValue = computed(() => {
+        const task = selectedTask()?.taskId;
+        if(!task) return "";
+
+        const path = expandedValue.value;
+        if(!path) return `{{ outputs.${task} }}`
+
+        return `{{ outputs.${path} }}`
+    });
     const debugError = ref("");
     const debugStackTrace = ref("");
     const isJSON = ref(false);
     const selectedTask = () => {
-        const filter = selected.value.length ? selected.value[0] : (cascader.value as any).menuList?.[0]?.panel?.expandingNode?.label;
+        const filter = selected.value?.length ? selected.value[0] : (cascader.value as any).menuList?.[0]?.panel?.expandingNode?.label;
         const taskRunList = [...execution.value.taskRunList];
         return taskRunList.find(e => e.taskId === filter);
     };
@@ -162,22 +177,41 @@
 
     const execution = computed(() => store.state.execution.execution);
 
-    const processedValue = (data): { label: string, regular: boolean; } => {
+    function isValidURL(url) {
+        try {
+            new URL(url);
+            return true;
+        } catch (e) {
+            return false;
+        }
+    }
+
+    const processedValue = (data) => {
         const regular = false;
 
-        if (!data.value && !data.children?.length) return {label: data.value, regular};
-        else if (data?.children?.length) {
+        if (!data.value && !data.children?.length) {
+            return {label: data.value, regular};
+        } else if (data?.children?.length) {
             const message = (length) => ({label: `${length} items`, regular});
             const length = data.children.length;
 
             return data.children[0].isFirstPass ? message(length - 1) : message(length);
         }
-        return data.value.toString().startsWith("kestra:///") ? {label: "Internal link", regular} : {label: trim(data.value), regular: true};
+
+        // Check if the value is a valid URL and not an internal "kestra:///" link
+        if (isValidURL(data.value)) {
+            return data.value.startsWith("kestra:///") 
+                ? {label: "Internal link", regular} 
+                : {label: "External link", regular};
+        }
+
+        return {label: trim(data.value), regular: true};
     };
 
+    const expandedValue = ref([])
     const selected = ref([]);
     const selectedValue = computed(() => {
-        if (selected.value.length) return selected.value[selected.value.length - 1];
+        if (selected.value?.length) return selected.value[selected.value.length - 1];
         return undefined;
     });
     const selectedNode = () => {
@@ -190,21 +224,34 @@
         return {label, value};
     };
 
-    const transform = (o, isFirstPass = true) => {
+    const transform = (o, isFirstPass, path = "") => {
         const result = Object.keys(o).map(key => {
             const value = o[key];
             const isObject = typeof value === "object" && value !== null;
 
+            const currentPath = `${path}["${key}"]`;
+
             // If the value is an array with exactly one element, use that element as the value
             if (Array.isArray(value) && value.length === 1) {
-                return {label: key, value: value[0], children: []};
+                return {label: key, value: value[0], children: [], path: currentPath};
             }
 
-            return {label: key, value: isObject && !Array.isArray(value) ? null : value, children: isObject ? transform(value, false) : []};
+            return {
+                label: key,
+                value: isObject && !Array.isArray(value) ? key : value,
+                children: isObject ? transform(value, false, currentPath) : [],
+                path: currentPath
+            };
         });
 
         if (isFirstPass) {
-            const OUTPUTS = {label: t("outputs"), heading: true, component: shallowRef(TextBoxSearchOutline), isFirstPass: true};
+            const OUTPUTS = {
+                label: t("outputs"),
+                heading: true,
+                component: shallowRef(TextBoxSearchOutline),
+                isFirstPass: true,
+                path: path
+            };
             result.unshift(OUTPUTS);
         }
 
@@ -212,7 +259,7 @@
     };
     const outputs = computed(() => {
         const tasks = store.state.execution.execution.taskRunList.map((task) => {
-            return {label: task.taskId, value: task.taskId, ...task, icon: true, children: task?.outputs ? transform(task.outputs) : []};
+            return {label: task.taskId, value: task.taskId, ...task, icon: true, children: task?.outputs ? transform(task.outputs, true, task.taskId) : []};
         });
 
         const HEADING = {label: t("tasks"), heading: true, component: shallowRef(TimelineTextOutline)};

ui/src/components/flows/Curl.vue

@@ -36,9 +36,23 @@
                 default: true
             }
         },
+        data() {
+            return {
+                exampleFileName: "kestra.json"
+            }
+        },
         computed: {
             curlCommand() {
-                return this.generateCurlCommand();
+                const mainCommand = this.generateCurlCommand();
+
+                if (this.flow.inputs && this.flow.inputs.find((input) => input.type === "FILE")) {
+                    return `${this.toShell(this.generatePrefix())} && \\\n${this.toShell(mainCommand)}`;
+                } else {
+                    return `${this.toShell(mainCommand)}`;
+                }
+            },
+            exampleFileInputUrl() {
+                return `https://huggingface.co/datasets/kestra/datasets/resolve/main/json/${this.exampleFileName}`;
             }
         },
         methods: {
@@ -55,16 +69,25 @@
 
                     switch (input.type) {
                     case "FILE": {
-                        const fileInput = this.inputs[input.id];
-                        if (fileInput) {
-                            inputValue = fileInput.name;
-                        }
+                        inputValue = this.exampleFileName;
                         break;
                     }
                     case "SECRET": {
                         inputValue = this.inputs[input.id] ? "******" : undefined;
                         break;
                     }
+                    case "DURATION": {
+                        inputValue = this.$moment.duration(this.$moment(this.inputs[input.id]).format("hh:mm:ss")).toJSON();
+                        break;
+                    }
+                    case "DATE": {
+                        inputValue = this.$moment(this.inputs[input.id]).format("YYYY-MM-DD");
+                        break;
+                    }
+                    case "TIME": {
+                        inputValue = this.$moment(this.inputs[input.id]).format("hh:mm:ss");
+                        break;
+                    }
                     default:
                         inputValue = this.inputs[input.id];
                     }
@@ -115,8 +138,22 @@
 
                 command.push(`'${this.generateUrl()}'`);
 
+                return command
+            },
+            generatePrefix() {
+                return ["curl", "-O", `'${this.exampleFileInputUrl}'`];
+            },
+            toShell(command) {
                 return command.join(" ");
             }
         }
     }
-</script>
+</script>
+
+<style lang="scss" scoped>
+    /* Allow line-wraps */
+    code {
+        display: block;
+        white-space: pre-wrap;
+    }
+</style>

ui/src/components/flows/FlowCreate.vue

@@ -59,7 +59,7 @@
             async setupFlow() {
                 if (this.$route.query.copy && this.flow){
                     this.source = this.flow.source;
-                } else if (this.$route.query.blueprintId) {
+                } else if (this.$route.query.blueprintId && this.$route.query.blueprintSource) {
                     this.source = await this.queryBlueprint(this.$route.query.blueprintId)
                 } else {
                     this.source = `id: myflow
@@ -86,7 +86,7 @@ tasks:
                 };
             },
             blueprintUri() {
-                return `${apiUrl(this.$store)}/blueprints/community`
+                return `${apiUrl(this.$store)}/blueprints/${this.$route.query.blueprintSource}`
             },
             flowParsed() {
                 return YamlUtils.parse(this.source);

ui/src/components/flows/FlowTriggers.vue

@@ -9,7 +9,7 @@
     >
         <el-table-column type="expand">
             <template #default="props">
-                <LogsWrapper class="m-3" :filters="props.row" :charts="false" embed />
+                <LogsWrapper class="m-3" :filters="props.row" purge-filters :charts="false" embed />
             </template>
         </el-table-column>
         <el-table-column prop="id" :label="$t('id')">

ui/src/components/flows/TaskEdit.vue

@@ -21,7 +21,7 @@
                         :icon="ContentSave"
                         @click="saveTask"
                         v-if="canSave && !readOnly"
-                        :disabled="errors"
+                        :disabled="errors && !!errors.length"
                         type="primary"
                     >
                         {{ $t("save task") }}
@@ -160,8 +160,7 @@
                     if (this.task) {
                         this.taskYaml = YamlUtils.stringify(this.task);
                         if (this.task.type) {
-                            this.$store
-                                .dispatch("plugin/load", {cls: this.task.type})
+                            this.$store.dispatch("plugin/load", {cls: this.task.type})
                         }
                     } else {
                         this.taskYaml = "";
@@ -173,8 +172,7 @@
                 handler() {
                     const task = YamlUtils.parse(this.taskYaml);
                     if (task?.type && task.type !== this.type) {
-                        this.$store
-                            .dispatch("plugin/load", {cls: task.type})
+                        this.$store.dispatch("plugin/load", {cls: task.type})
                         this.type = task.type
                     }
                 },

ui/src/components/flows/TaskEditor.vue

@@ -109,7 +109,7 @@
                     type: this.selectedTaskType
                 };
 
-                if (this.section !== SECTIONS.TRIGGERS) {
+                if (this.section !== SECTIONS.TRIGGERS && this.section !== SECTIONS.TASK_RUNNERS) {
                     value["id"] = this.taskObject && this.taskObject.id ? this.taskObject.id : "";
                 }
 

ui/src/components/flows/Topology.vue

@@ -11,6 +11,7 @@
                 :expanded-subflows="expandedSubflows"
                 view-type="topology"
                 @expand-subflow="onExpandSubflow($event)"
+                @on-edit="(event) => emit('on-edit', event, true)"
             />
             <el-alert v-else type="warning" :closable="false">
                 {{ $t("unable to generate graph") }}
@@ -27,7 +28,7 @@
             LowCodeEditor,
         },
         emits: [
-            "expand-subflow"
+            "expand-subflow", "on-edit"
         ],
         props: {
             isReadOnly: {

ui/src/components/flows/blueprints/BlueprintDetail.vue

@@ -41,8 +41,17 @@
             <el-col :md="24" :lg="embed ? 24 : 18">
                 <h4>{{ $t("source") }}</h4>
                 <el-card>
-                    <editor class="position-relative" :read-only="true" :input="true" :full-height="false" :minimap="false" :model-value="blueprint.flow" lang="yaml">
-                        <template #nav>
+                    <editor
+                        class="position-relative"
+                        :read-only="true"
+                        :input="true"
+                        :full-height="false"
+                        :minimap="false"
+                        :model-value="blueprint.flow"
+                        lang="yaml"
+                        :navbar="false"
+                    >
+                        <template #absolute>
                             <copy-to-clipboard class="position-absolute" :text="blueprint.flow" />
                         </template>
                     </editor>
@@ -91,7 +100,7 @@
                         label: this.$t("blueprints.title"),
                         link: {
                             name: "blueprints",
-                            params: this.$route.params
+                            params: this.$route.params.tab ? this.$route.params.tab : {...this.$route.params, tab: this.tab},
                         }
                     }
                 ]
@@ -109,6 +118,10 @@
             tab: {
                 type: String,
                 default: "community"
+            },
+            blueprintBaseUri: {
+                type: String,
+                default: undefined,
             }
         },
         methods: {
@@ -119,22 +132,26 @@
                     this.$router.push({
                         name: "blueprints",
                         params: {
-                            tenant: this.$route.params.tenant
+                            tenant: this.$route.params.tenant,
+                            tab: this.tab
                         }
                     })
                 }
             }
         },
         async created() {
-            this.blueprint = (await this.$http.get(`${this.blueprintBaseUri}/${this.blueprintId}`)).data
+            const TAB = this.$route.query?.tab ?? (this.embed ? this.tab : (this.$route?.params?.tab ?? "community"));
+            const URL = this.blueprintBaseUri ?? `${apiUrl(this.$store)}/blueprints/` + TAB;
+
+            this.blueprint = (await this.$http.get(`${URL}/${this.blueprintId}`)).data;
 
             try {
-                if (this.blueprintBaseUri.endsWith("community")) {
+                if (this.blueprintBaseUri?.endsWith("community")) {
                     this.flowGraph = (await this.$http.get(`${this.blueprintBaseUri}/${this.blueprintId}/graph`, {
                         validateStatus: (status) => {
                             return status === 200;
                         }
-                    })).data;
+                    }))?.data;
                 } else {
                     this.flowGraph = await this.$store.dispatch("flow/getGraphFromSourceResponse", {
                         flow: this.blueprint.flow, config: {
@@ -159,9 +176,6 @@
                     ...YamlUtils.parse(this.blueprint.flow),
                     source: this.blueprint.flow
                 }
-            },
-            blueprintBaseUri() {
-                return `${apiUrl(this.$store)}/blueprints/` + (this.embed ? this.tab : (this.$route?.params?.tab ?? "community"));
             }
         }
     };
@@ -257,4 +271,4 @@
             }
         }
     }
-</style>
+</style>

ui/src/components/flows/tasks/Task.js

@@ -49,6 +49,10 @@ export default {
                     return "condition"
                 }
 
+                if (property.$ref.includes("tasks.runners.TaskRunner")) {
+                    return "task-runner"
+                }
+
                 return "complex";
             }
 

ui/src/components/flows/tasks/TaskArray.vue

@@ -32,13 +32,13 @@
         mixins: [Task],
         emits: ["update:modelValue"],
         created() {
-            if (!Array.isArray(this.modelValue)) {
+            if (!Array.isArray(this.modelValue) && this.modelValue !== undefined) {
                 this.$emit("update:modelValue", []);
             }
         },
         computed: {
             values() {
-                if (this.modelValue === undefined || (Array.isArray(this.modelValue) && this.modelValue.length === 0)) {
+                if (this.modelValue === undefined) {
                     return this.schema.default || [undefined];
                 }
 

ui/src/components/flows/tasks/TaskTask.vue

@@ -19,7 +19,7 @@
             <task-editor
                 ref="editor"
                 :model-value="taskYaml"
-                :section="SECTIONS.TASKS"
+                :section="section"
                 @update:model-value="onInput"
             />
         </el-form>
@@ -34,7 +34,6 @@
 <script setup>
     import TextSearch from "vue-material-design-icons/TextSearch.vue";
     import ContentSave from "vue-material-design-icons/ContentSave.vue";
-    import {SECTIONS} from "../../../utils/constants.js";
 </script>
 
 <script>
@@ -42,11 +41,18 @@
     import YamlUtils from "../../../utils/yamlUtils";
     import TaskEditor from "../TaskEditor.vue"
     import Drawer from "../../Drawer.vue"
+    import {SECTIONS as SECTION} from "../../../utils/constants.js";
 
     export default {
         mixins: [Task],
         components: {TaskEditor, Drawer},
         emits: ["update:modelValue"],
+        props: {
+            section: {
+                type: String,
+                default: SECTION.TASKS
+            },
+        },
         data() {
             return {
                 isOpen: false,

ui/src/components/flows/tasks/TaskTaskRunner.vue

@@ -0,0 +1,9 @@
+<template>
+    <task-task @update:model-value="$emit('update:modelValue', $event)" v-bind="$attrs" :section="SECTION.TASK_RUNNERS" />
+</template>
+<script setup>
+    import {SECTIONS as SECTION} from "../../../utils/constants.js";
+    import TaskTask from "./TaskTask.vue";
+
+    defineEmits(["update:modelValue"]);
+</script>

ui/src/components/home/Home.vue

@@ -45,6 +45,14 @@
                         @update:filter-value="updateQuery"
                     />
                 </el-form-item>
+                <el-form-item>
+                    <scope-filter-buttons
+                        :label="$t('data')"
+                        :value="scope"
+                        :system="namespace === 'system'"
+                        @update:model-value="onScopeSelect"
+                    />
+                </el-form-item>
                 <el-form-item>
                     <refresh-button class="float-right" @refresh="load" :can-auto-refresh="canAutoRefresh" />
                 </el-form-item>
@@ -236,7 +244,8 @@
                 namespaceRestricted: !!this.namespace,
                 refreshDates: false,
                 canAutoRefresh: false,
-                state: []
+                state: [],
+                scope: []
             };
         },
         methods: {

ui/src/components/inputs/Editor.vue

@@ -27,7 +27,7 @@
                 </div>
             </slot>
         </nav>
-
+        <slot name="absolute" />
         <div class="editor-container" ref="container" :class="containerClass">
             <div ref="editorContainer" class="editor-wrapper position-relative">
                 <monaco-editor
@@ -96,7 +96,7 @@
         components: {
             MonacoEditor,
         },
-        emits: ["save", "execute", "focusout", "tab", "update:modelValue", "cursor"],
+        emits: ["save", "execute", "focusout", "tab", "update:modelValue", "cursor", "confirm"],
         editor: undefined,
         data() {
             return {
@@ -155,11 +155,14 @@
                         vertical: "hidden",
                         horizontal: "hidden",
                         alwaysConsumeMouseWheel: false,
-                        handleMouseWheel: false,
+                        handleMouseWheel: true,
                         horizontalScrollbarSize: 0,
                         verticalScrollbarSize: 0,
                         useShadows: false,
                     };
+                    options.stickyScroll = {
+                        enabled: false
+                    };
                     options.find = {
                         addExtraSpaceOnTop: false,
                         autoFindInSelection: "never",
@@ -262,6 +265,19 @@
                     }
                 });
 
+                this.editor.addAction({
+                    id: "confirm",
+                    label: "Confirm",
+                    keybindings: [
+                        KeyMod.CtrlCmd | KeyCode.Enter,
+                    ],
+                    contextMenuGroupId: "navigation",
+                    contextMenuOrder: 1.5,
+                    run: (ed) => {
+                        this.$emit("confirm", ed.getValue())
+                    }
+                });
+
                 // TabFocus is global to all editor so revert the behavior on non inputs
                 this.editor.onDidFocusEditorText?.(() => {
                     TabFocus.setTabFocusMode(this.input);
@@ -316,6 +332,7 @@
 
                 if (!this.fullHeight) {
                     editor.onDidContentSizeChange(e => {
+                        if(!this.$refs.container) return;                    
                         this.$refs.container.style.height = (e.contentHeight + this.customHeight) + "px";
                     });
                 }

ui/src/components/inputs/EditorView.vue

@@ -120,10 +120,10 @@
 
     const isCurrentTabFlow = computed(() => currentTab?.value?.extension === undefined)
 
-    const flowErrors = computed(() => {
-        const isFlow = currentTab?.value?.flow;
+    const isFlow = () => currentTab?.value?.flow || props.isCreating;
 
-        if (isFlow) {
+    const flowErrors = computed(() => {
+        if (isFlow()) {
             const flowExistsError =
                 props.flowValidation?.outdated && props.isCreating
                     ? [outdatedMessage.value]
@@ -152,9 +152,7 @@
     });
 
     const flowWarnings = computed(() => {
-        const isFlow = currentTab?.value?.flow;
-
-        if (isFlow) {
+        if (isFlow()) {
             const outdatedWarning =
                 props.flowValidation?.outdated && !props.isCreating
                     ? [outdatedMessage.value]
@@ -283,9 +281,7 @@
     );
 
     const flowHaveTasks = (source) => {
-        const isFlow = currentTab?.value?.flow || props.isCreating; 
-
-        if (isFlow) {
+        if (isFlow()) {
             const flow = props.isCreating ? props.flow.source : (source ? source : flowYaml.value);
             return flow ? YamlUtils.flowHaveTasks(flow) : false;
         } else return false;
@@ -441,10 +437,10 @@
         });
     };
 
-    const onEdit = (event, isFlow = false) => {
+    const onEdit = (event, currentIsFlow = false) => {
         flowYaml.value = event;
 
-        if (isFlow) {
+        if (currentIsFlow) {
             if (
                 flowParsed.value &&
                 !props.isCreating &&
@@ -467,9 +463,20 @@
 
         haveChange.value = true;
         store.dispatch("core/isUnsaved", true);
+
+        if(!props.isCreating){
+            store.commit("editor/changeOpenedTabs", {
+                action: "dirty",
+                ...currentTab.value,
+                name: currentTab.value?.name ?? "Flow",
+                path: currentTab.value?.path ?? "Flow.yaml",
+                dirty: true
+            });
+        }
+
         clearTimeout(timer.value);
 
-        if(!isFlow) return;
+        if(!currentIsFlow) return;
 
         return store
             .dispatch("flow/validateFlow", {flow: yamlWithNextRevision.value})
@@ -591,13 +598,13 @@
     };
 
     const editorUpdate = (event) => {
-        const isFlow = currentTab?.value?.flow;
+        const currentIsFlow = isFlow();
 
         updatedFromEditor.value = true;
         flowYaml.value = event;
 
         clearTimeout(timer.value);
-        timer.value = setTimeout(() => onEdit(event, isFlow), 500);
+        timer.value = setTimeout(() => onEdit(event, currentIsFlow), 500);
     };
 
     const switchViewType = (event, shouldPersist = true) => {
@@ -611,7 +618,7 @@
         ) {
             isHorizontal.value = isHorizontalDefault();
             if (updatedFromEditor.value) {
-                onEdit(flowYaml.value);
+                onEdit(flowYaml.value, true);
                 updatedFromEditor.value = false;
             }
         }
@@ -711,9 +718,7 @@
             }
         }
 
-        const isFlow = currentTab?.value?.flow || props.isCreating;
-
-        if (isFlow) {
+        if (isFlow()) {
             onEdit(flowYaml.value, true).then((validation) => {
                 if (validation.outdated && !props.isCreating) {
                     confirmOutdatedSaveDialog.value = true;
@@ -734,7 +739,7 @@
             });
         } else {
             await store.dispatch("namespace/createFile", {
-                namespace: props.namespace,
+                namespace: props.namespace ?? routeParams.id,
                 path: currentTab.value.path ?? currentTab.value.name,
                 content: editorDomElement.value.$refs.monacoEditor.value,
             });
@@ -1064,7 +1069,7 @@
                     v-if="flowGraph"
                     ref="lowCodeEditorRef"
                     @follow="forwardEvent('follow', $event)"
-                    @on-edit="(e) => onEdit(e, true)"
+                    @on-edit="(event, isFlow) => onEdit(event, isFlow)"
                     @loading="loadingState"
                     @expand-subflow="onExpandSubflow"
                     @swapped-task="onSwappedTask"

ui/src/components/inputs/InputsForm.vue

@@ -42,7 +42,7 @@
                 multiple
             >
                 <el-option
-                    v-for="item in input.options"
+                    v-for="item in (input.values ?? input.options)"
                     :key="item"
                     :label="item"
                     :value="item"

ui/src/components/inputs/LowCodeEditor.vue

@@ -156,7 +156,7 @@
                     });
                     return;
                 }
-                emit("on-edit", YamlUtils.deleteTask(props.source, event.id, section))
+                emit("on-edit", YamlUtils.deleteTask(props.source, event.id, section), true)
             },
             () => {
             }
@@ -197,17 +197,17 @@
         if (task === undefined || (task && YamlUtils.parse(event).id === taskEditData.value.oldTaskId)) {
             switch (taskEditData.value.action) {
             case("create_task"):
-                emit("on-edit", YamlUtils.insertTask(source, taskEditData.value.insertionDetails[0], event, taskEditData.value.insertionDetails[1]))
+                emit("on-edit", YamlUtils.insertTask(source, taskEditData.value.insertionDetails[0], event, taskEditData.value.insertionDetails[1]), true)
                 return;
             case("edit_task"):
                 emit("on-edit", YamlUtils.replaceTaskInDocument(
                     source,
                     taskEditData.value.oldTaskId,
                     event
-                ))
+                ), true)
                 return;
             case("add_flowable_error"):
-                emit("on-edit", YamlUtils.insertErrorInFlowable(props.source, event, taskEditData.value.taskId))
+                emit("on-edit", YamlUtils.insertErrorInFlowable(props.source, event, taskEditData.value.taskId), true)
                 return;
             }
         } else {
@@ -276,7 +276,7 @@
 
     const onSwappedTask = (event) => {
         emit("swapped-task", event.swappedTasks);
-        emit("on-edit", event.newSource);
+        emit("on-edit", event.newSource, true);
     }
 
     const message = (event) => {

ui/src/components/inputs/MonacoEditor.vue

@@ -604,7 +604,7 @@
                 };
 
                 if (this.diffEditor) {
-                    this.editor = monaco.editor.createDiffEditor(this.$el, options);
+                    this.editor = monaco.editor.createDiffEditor(this.$el, {...options, ignoreTrimWhitespace: false});
                     let originalModel = monaco.editor.createModel(this.original, this.language);
                     let modifiedModel = monaco.editor.createModel(this.value, this.language);
                     this.editor.setModel({
@@ -620,10 +620,10 @@
                     this.editor = monaco.editor.create(this.$el, options);
 
                     if(!this.input){
-                        const name = this.currentTab?.path ?? this.currentTab?.name;            
+                        const name = this.currentTab?.path ?? this.currentTab?.name;
                         const value = this.currentTab?.flow || this.creating ? this.value : this.readFile({namespace: this.$route.params.namespace || this.$route.params.id, path: name})
 
-                        await this.changeTab(name, () => value);
+                        await this.changeTab(name, () => value, false);
                     }
                 }
 
@@ -712,4 +712,12 @@
         height: 100%;
         outline: none;
     }
+</style>
+
+<style lang="scss">
+    @import "../../styles/layout/root-dark.scss";
+
+    .custom-dark-vs-theme .monaco-editor .sticky-widget {
+        background-color: $input-bg;        
+    }
 </style>

ui/src/components/layout/CopyToClipboard.vue

@@ -1,7 +1,11 @@
 <template>
     <div class="copy-wrapper">
         <el-tooltip trigger="click" :content="$t('copied')" placement="left" :auto-close="2000" effect="light">
-            <el-button text round :icon="ContentCopy" @click="Utils.copy(text)" />
+            <el-button text round :icon="ContentCopy" @click="Utils.copy(text)">
+                <span v-if="label">
+                    {{ label }}
+                </span>
+            </el-button>
         </el-tooltip>
     </div>
 </template>
@@ -18,6 +22,11 @@
             text: {
                 type: String,
                 required: true
+            },
+            label: {
+                type: String,
+                required: false,
+                default: undefined
             }
         }
     }

ui/src/components/layout/TopNavBar.vue

@@ -124,6 +124,7 @@
         },
         computed: {
             ...mapState("api", ["version"]),
+            ...mapState("core", ["tutorialFlows"]),
             ...mapGetters("core", ["guidedProperties"]),
             ...mapGetters("auth", ["user"]),
             displayNavBar() {
@@ -131,7 +132,7 @@
             },
             tourEnabled(){
                 // Temporary solution to not showing the tour menu item for EE
-                return !Object.keys(this.user).length
+                return this.tutorialFlows?.length && !Object.keys(this.user).length
             }
         },
         methods: {

ui/src/components/logs/LogLine.vue

@@ -1,5 +1,5 @@
 <template>
-    <div class="line font-monospace" v-if="filtered">
+    <div class="py-2 line font-monospace" v-if="filtered">
         <span :class="levelClass" class="header-badge log-level el-tag noselect fw-bold">{{ log.level }}</span>
         <div class="log-content d-inline-block">
             <span v-if="title" class="fw-bold">{{ (log.taskId ?? log.flowId ?? "").capitalize() }}</span>

ui/src/components/logs/LogsWrapper.vue

@@ -56,9 +56,9 @@
                         </div>
                     </el-card>
 
-                    <el-button v-if="!isLogsListing && logs !== undefined && logs.length > 0" @click="deleteLogs()" class="mb-3 delete-logs-btn">
+                    <el-button v-if="shouldDisplayDeleteButton && logs !== undefined && logs.length > 0" @click="deleteLogs()" class="mb-3 delete-logs-btn">
                         <TrashCan class="me-2" />
-                        <span>{{ $t("delete logs") }}</span>                     
+                        <span>{{ $t("delete logs") }}</span>
                     </el-button>
                 </template>
 
@@ -126,7 +126,11 @@
             filters: {
                 type: Object,
                 default: null
-            }
+            },
+            purgeFilters: {
+                type: Boolean,
+                default: false
+            },
         },
         data() {
             return {
@@ -153,8 +157,8 @@
             isFlowEdit() {
                 return this.$route.name === "flows/update"
             },
-            isLogsListing() {
-                return this.$route.name === "logs/list"
+            shouldDisplayDeleteButton() {
+                return this.$route.name === "flows/update"
             },
             isNamespaceEdit() {
                 return this.$route.name === "namespaces/update"
@@ -204,7 +208,9 @@
                 this.load();
             },
             loadQuery(base) {
-                let queryFilter = this.filters ? this.filters : this.queryWithFilter();
+                // eslint-disable-next-line no-unused-vars
+                const {triggerId, ...rest} = this.filters || {};
+                let queryFilter = this.filters ? (this.purgeFilters ? rest : this.filters) : this.queryWithFilter();
 
                 if (this.isFlowEdit) {
                     queryFilter["namespace"] = this.namespace;
@@ -225,13 +231,17 @@
             load() {
                 this.isLoading = true
 
-                const data = this.filters 
-                    ? {page: this.internalPageNumber, size: this.internalPageSize, ...this.filters} 
-                    : {page: this.$route.query.page || this.internalPageNumber, size: this.$route.query.size || this.internalPageSize}
+                // eslint-disable-next-line no-unused-vars
+                const {triggerId, ...rest} = this.filters || {};
+                const data = {
+                    page: this.filters ? this.internalPageNumber : this.$route.query.page || this.internalPageNumber,
+                    size: this.filters ? this.internalPageSize : this.$route.query.size || this.internalPageSize,
+                    ...(this.purgeFilters ? rest : this.filters)
+                };
 
                 this.$store
                     .dispatch("log/findLogs", this.loadQuery({
-                        ...data,                      
+                        ...data,
                         minLevel: this.filters ? null : this.selectedLogLevel,
                         sort: "timestamp:desc"
                     }))
@@ -279,6 +289,7 @@
             border-radius: var(--bs-border-radius-lg);
             overflow: hidden;
             padding: $spacer;
+            padding-top: calc($spacer/2);
             background-color: var(--bs-white);
             border: 1px solid var(--bs-border-color);
 

ui/src/components/namespace/Namespace.vue

@@ -115,7 +115,32 @@
                         query: {
                             id: this.$route.query.id
                         }
-                    },                   
+                    },   
+                    {
+                        name: "dependencies",
+                        component: NamespaceDependenciesWrapper,
+                        title: this.$t("dependencies"),
+                        props: {
+                            type: "dependencies",
+                            tab: "dependencies",
+                        },
+                        query: {
+                            id: this.$route.query.id
+                        }
+                    },      
+                    {
+                        name: "kv",
+                        component: NamespaceKV,
+                        title: this.$t("kv.name"),
+                        props: {
+                            addKvModalVisible: this.modalAddKvVisible,
+                        },
+                        "v-on": {
+                            "update:addKvModalVisible": (value) => {
+                                this.modalAddKvVisible = value
+                            }
+                        }
+                    },          
                     {
                         name: "edit",
                         component: "",
@@ -152,19 +177,7 @@
                         },
                         disabled: true,
                         locked: true
-                    },
-                    {
-                        name: "dependencies",
-                        component: NamespaceDependenciesWrapper,
-                        title: this.$t("dependencies"),
-                        props: {
-                            type: "dependencies",
-                            tab: "dependencies",
-                        },
-                        query: {
-                            id: this.$route.query.id
-                        }
-                    },
+                    },              
                     {
                         name: "secrets",
                         component: "",
@@ -193,20 +206,7 @@
                         },
                         disabled: true,
                         locked: true
-                    },
-                    {
-                        name: "kv",
-                        component: NamespaceKV,
-                        title: this.$t("kv.name"),
-                        props: {
-                            addKvModalVisible: this.modalAddKvVisible,
-                        },
-                        "v-on": {
-                            "update:addKvModalVisible": (value) => {
-                                this.modalAddKvVisible = value
-                            }
-                        }
-                    }
+                    }             
                 ])
 
                 return tabs;

ui/src/components/namespace/NamespaceDependenciesWrapper.vue

@@ -1,14 +1,7 @@
 <template>
-    <NamespaceDependencies :namespace="namespace" />
+    <NamespaceDependencies :namespace="$route.params.id" />
 </template>
 
 <script setup>
-    import {computed} from "vue";
-
-    import {useRoute} from "vue-router";
-    const route = useRoute();
-
-    const namespace = computed(() => route.params.id);
-
     import NamespaceDependencies from "./NamespaceDependencies.vue";
 </script>

ui/src/components/namespace/Namespaces.vue

@@ -31,7 +31,8 @@
                     <router-link :to="{name: 'namespaces/update', params: {id: data.id}}" tag="div" class="node">
                         <div class="d-flex">
                             <VectorIntersection class="me-2 icon" />
-                            <span>{{ data.label }}</span>
+                            <span class="pe-3">{{ namespaceLabel(data.label) }}</span>
+                            <span v-if="data.system" class="system">{{ $t("system_namespace") }}</span>
                         </div>
                         <el-button size="small">
                             <TextSearch />
@@ -122,6 +123,11 @@
 
         return build(map);
     };
+
+    const namespaceLabel = (path) => {
+        const segments = path.split(".");
+        return segments.length > 1 ? segments[segments.length - 1] : path;
+    };
 </script>
 
 <style lang="scss">

ui/src/components/onboarding/VueTour.vue

@@ -27,7 +27,7 @@
                         <div
                             v-if="currentStep(tour).title"
                             class="title"
-                            :class="{dark: currentStep(tour).keepDark}"
+                            :class="{dark: currentStep(tour).keepDark, empty: !flows.length}"
                         >
                             <div v-if="currentStep(tour).icon">
                                 <img
@@ -35,7 +35,7 @@
                                     :class="{jump: currentStep(tour).jump}"
                                 >
                             </div>
-                            <span v-html="currentStep(tour).title" />
+                            <span v-html="tour.currentStep === 1 && !flows.length ? t('onboarding.no_flows') : currentStep(tour).title" />
                         </div>
                     </template>
                     <template #content>
@@ -68,10 +68,6 @@
                                             :icons="icons"
                                             :variable="ICON_COLOR"
                                             only-icon
-
-                                            :data-cls="task"
-                                            :data-task-index="taskIndex"
-                                            :data-key="`flow__${flowIndex}__icon__${taskIndex}`"
                                         />
                                     </div>
                                 </div>
@@ -99,6 +95,7 @@
                                     ![0, 1].includes(tour.currentStep) ||
                                         !tour.isLast
                                 "
+                                :disabled="tour.currentStep === 1 && !flows.length"
                                 @click="
                                     tour.isLast
                                         ? finishTour(tour.currentStep)
@@ -147,7 +144,6 @@
 
     import Finish from "./components/buttons/Finish.vue";
 
-    import {apiUrl} from "override/utils/route";
     import {pageFromRoute} from "../../utils/eventsRouter";
 
     import TaskIcon from "@kestra-io/ui-libs/src/components/misc/TaskIcon.vue";
@@ -208,7 +204,7 @@
     };
 
     const activeFlow = ref(0);
-    const flows = ref([]);
+    const flows = computed(() => store.state.core.tutorialFlows);
 
     const allTasks = (tasks) => {
         const uniqueTypes = new Set();
@@ -300,7 +296,7 @@
                     name: "flows/update",
                     params: {
                         namespace: "tutorial",
-                        id: flows.value[activeFlow.value].id,
+                        id: flows.value[activeFlow.value]?.id,
                         tab: "editor",
                     },
                 });
@@ -312,7 +308,7 @@
                 store.commit("editor/updateOnboarding"),
                 store.commit("core/setGuidedProperties", {
                     tourStarted: true,
-                    template: flows.value[activeFlow.value].id,
+                    template: flows.value[activeFlow.value]?.id,
                 });
 
                 wait(1);
@@ -422,11 +418,7 @@
     };
 
     onMounted(() => {
-        const HTTP = getCurrentInstance()?.appContext.config.globalProperties.$http;
-
-        HTTP.get(`${apiUrl(this)}/flows/tutorial`).then(
-            (response) => (flows.value = response.data),
-        );
+        store.dispatch("core/readTutorialFlows");
     });
 </script>
 
@@ -530,6 +522,11 @@ $flow-image-size-container: 36px;
         font-weight: 500;
         color: $color;
 
+        &.empty {
+            font-size: 1.2rem;
+            margin-bottom: 0;
+        }
+
         & div {
             height: 2rem;
             margin-bottom: 1rem;

ui/src/components/plugins/PluginHome.vue

@@ -20,7 +20,7 @@
         <el-tooltip v-for="(plugin, index) in pluginsList" :show-after="1000" :key="index" effect="light">
             <template #content>
                 <div class="tasks-tooltips">
-                    <p v-if="plugin?.tasks.filter(t => t.toLowerCase().includes(searchInput)).length > 0">
+                    <p v-if="plugin?.tasks.filter(t => t.toLowerCase().includes(searchInput)).length > 0" class="mb-0">
                         Tasks
                     </p>
                     <ul>
@@ -31,7 +31,7 @@
                             <span @click="openPlugin(task)">{{ task }}</span>
                         </li>
                     </ul>
-                    <p v-if="plugin?.triggers.filter(t => t.toLowerCase().includes(searchInput)).length > 0">
+                    <p v-if="plugin?.triggers.filter(t => t.toLowerCase().includes(searchInput)).length > 0" class="mb-0">
                         Triggers
                     </p>
                     <ul>
@@ -42,7 +42,7 @@
                             <span @click="openPlugin(trigger)">{{ trigger }}</span>
                         </li>
                     </ul>
-                    <p v-if="plugin?.conditions.filter(t => t.toLowerCase().includes(searchInput)).length > 0">
+                    <p v-if="plugin?.conditions.filter(t => t.toLowerCase().includes(searchInput)).length > 0" class="mb-0">
                         Conditions
                     </p>
                     <ul>
@@ -53,7 +53,7 @@
                             <span @click="openPlugin(condition)">{{ condition }}</span>
                         </li>
                     </ul>
-                    <p v-if="plugin?.taskRunners.filter(t => t.toLowerCase().includes(searchInput)).length > 0">
+                    <p v-if="plugin?.taskRunners.filter(t => t.toLowerCase().includes(searchInput)).length > 0" class="mb-0">
                         Task
                         Runners
                     </p>
@@ -140,8 +140,8 @@
                             plugin.conditions.some(condition => condition.toLowerCase().includes(this.searchInput.toLowerCase())) ||
                             plugin.taskRunners.some(taskRunner => taskRunner.toLowerCase().includes(this.searchInput.toLowerCase()))
                     }).sort((a, b) => {
-                        const nameA = a.group.toLowerCase(),
-                              nameB = b.group.toLowerCase();
+                        const nameA = a.manifest["X-Kestra-Title"].toLowerCase(),
+                              nameB = b.manifest["X-Kestra-Title"].toLowerCase();
 
                         return (nameA < nameB ? -1 : (nameA > nameB ? 1 : 0));
                     })

ui/src/components/plugins/PluginSelect.vue

@@ -55,12 +55,17 @@
             taskModels() {
                 const taskModels = [];
                 for (const plugin of this.plugins || []) {
-                    taskModels.push.apply(taskModels, plugin[this.section.toLowerCase()]);
+                    taskModels.push.apply(taskModels, plugin[this.upperSnakeToCamelCase(this.section)]);
                 }
                 return taskModels;
             },
         },
         methods: {
+            upperSnakeToCamelCase(str) {
+                return str.toLowerCase().replaceAll(/_([a-z])/g, function (g) {
+                    return g[1].toUpperCase();
+                });
+            },
             onInput(value) {
                 this.$emit("update:modelValue", value);
             },

ui/src/mixins/dataTableActions.js

@@ -86,6 +86,8 @@ export default {
             this.$router.push({query: query})
         },
         onPageChanged(item) {
+            if(this.internalPageSize === item.size && this.internalPageNumber === item.page) return;
+
             this.internalPageSize = item.size;
             this.internalPageNumber = item.page;
 

ui/src/override/components/flows/blueprints/Blueprints.vue

@@ -2,7 +2,7 @@
     <top-nav-bar v-if="!embed" :title="routeInfo.title" />
     <blueprints-page-header v-if="!embed" class="ms-0 mw-100" />
     <section :class="{'container': !embed}" class="main-container" v-bind="$attrs">
-        <blueprint-detail v-if="selectedBlueprintId" :embed="embed" :blueprint-id="selectedBlueprintId" @back="selectedBlueprintId = undefined" />
+        <blueprint-detail v-if="selectedBlueprintId" :embed="embed" :blueprint-id="selectedBlueprintId" @back="selectedBlueprintId = undefined" :blueprint-base-uri="blueprintUri" />
         <blueprints-browser @loaded="$emit('loaded', $event)" :class="{'d-none': !!selectedBlueprintId}" :embed="embed" :blueprint-base-uri="blueprintUri" @go-to-detail="blueprintId => selectedBlueprintId = blueprintId" />
     </section>
 </template>

ui/src/override/components/flows/blueprints/BlueprintsBrowser.vue

@@ -4,7 +4,7 @@
         <slot name="nav" />
         <data-table class="blueprints" @page-changed="onPageChanged" ref="dataTable" :total="total" divider>
             <template #navbar>
-                <el-radio-group v-if="ready" v-model="selectedTag" class="tags-selection">
+                <el-radio-group v-if="ready && !system" v-model="selectedTag" class="tags-selection">
                     <el-radio-button
                         :key="0"
                         :value="0"
@@ -17,17 +17,26 @@
                         :key="tag.id"
                         :value="tag.id"
                         class="hoverable"
+                        @dblclick.stop="selectedTag = 0"
                     >
                         {{ tag.name }}
                     </el-radio-button>
                 </el-radio-group>
+                <nav v-else-if="system" class="header pb-3">
+                    <p class="mb-0 fw-lighter">
+                        {{ $t("system_namespace") }}
+                    </p>
+                    <p class="fs-5 fw-semibold">
+                        {{ $t("system_namespace_description") }}
+                    </p>
+                </nav>
             </template>
             <template #search>
                 <search-field :router="!embed" placeholder="search blueprint" @search="s => q = s" class="blueprints-search" />
             </template>
             <template #table>
                 <el-alert type="info" v-if="!blueprints || blueprints.length === 0" :closable="false">
-                    {{ $t('no result') }}
+                    {{ $t('blueprints.empty') }}
                 </el-alert>
                 <el-card
                     class="blueprint-card"
@@ -39,14 +48,14 @@
                     <component
                         class="blueprint-link"
                         :is="embed ? 'div' : 'router-link'"
-                        :to="embed ? undefined : {name: 'blueprints/view', params: {blueprintId: blueprint.id}}"
+                        :to="embed ? undefined : {name: 'blueprints/view', params: {blueprintId: blueprint.id, tab}}"
                     >
                         <div class="left">
                             <div>
                                 <div class="title">
                                     {{ blueprint.title }}
                                 </div>
-                                <div class="tags text-uppercase">
+                                <div v-if="!system" class="tags text-uppercase">
                                     {{ tagsToString(blueprint.tags) }}
                                 </div>
                             </div>
@@ -72,7 +81,7 @@
                                     {{ $t('copy') }}
                                 </el-button>
                             </el-tooltip>
-                            <el-button v-else-if="userCanCreateFlow" size="large" text bg @click="blueprintToEditor(blueprint.id)">
+                            <el-button v-else size="large" text bg @click.prevent.stop="blueprintToEditor(blueprint.id)">
                                 {{ $t('use') }}
                             </el-button>
                         </div>
@@ -98,6 +107,7 @@
     import Utils from "../../../../utils/utils";
     import Errors from "../../../../components/errors/Errors.vue";
     import {editorViewTypes} from "../../../../utils/constants";
+    import {apiUrl} from "override/utils/route.js";
 
     export default {
         mixins: [RestoreUrl, DataTableActions],
@@ -108,10 +118,18 @@
                 type: String,
                 required: true
             },
+            tab: {
+                type: String,
+                default: undefined,
+            },
             embed: {
                 type: Boolean,
                 default: false
             },
+            system: {
+                type: Boolean,
+                default: false
+            },
             tagsResponseMapper: {
                 type: Function,
                 default: tagsResponse => Object.fromEntries(tagsResponse.map(tag => [tag.id, tag]))
@@ -136,7 +154,7 @@
             },
             async copy(blueprintId) {
                 await Utils.copy(
-                    (await this.$http.get(`${this.blueprintBaseUri}/${blueprintId}/flow`)).data
+                    (await this.$http.get(`${this.embedFriendlyBlueprintBaseUri}/${blueprintId}/flow`)).data
                 );
             },
             async blueprintToEditor(blueprintId) {
@@ -146,7 +164,7 @@
                     params: {
                         tenant: this.$route.params.tenant
                     },
-                    query: {blueprintId: blueprintId}
+                    query: {blueprintId: blueprintId, blueprintSource: this.embedFriendlyBlueprintBaseUri.includes("community") ? "community" : "custom"}
                 });
             },
             tagsToString(blueprintTags) {
@@ -169,7 +187,7 @@
                     })
                     .then(response => {
                         // Handle switch tab while fetching data
-                        if (this.blueprintBaseUri === beforeLoadBlueprintBaseUri) {
+                        if (this.embedFriendlyBlueprintBaseUri === beforeLoadBlueprintBaseUri) {
                             this.tags = this.tagsResponseMapper(response.data);
                         }
                     })
@@ -190,9 +208,10 @@
                     query.q = this.$route.query.q || this.q;
                 }
 
-
-                if (this.$route.query.selectedTag || this.selectedTag) {
-                    query.tags = this.$route.query.selectedTag || this.selectedTag;
+                if (this.system) {
+                    query.tags = "54";
+                } else if (this.$route.query.selectedTag || this.selectedTag) {
+                    query.tags =this.$route.query.selectedTag || this.selectedTag;
                 }
 
                 return this.$http
@@ -201,7 +220,7 @@
                     })
                     .then(response => {
                         // Handle switch tab while fetching data
-                        if (this.blueprintBaseUri === beforeLoadBlueprintBaseUri) {
+                        if (this.embedFriendlyBlueprintBaseUri === beforeLoadBlueprintBaseUri) {
                             const blueprintsResponse = response.data;
                             this.total = blueprintsResponse.total;
                             this.blueprints = blueprintsResponse.results;
@@ -209,7 +228,7 @@
                     });
             },
             loadData(callback) {
-                const beforeLoadBlueprintBaseUri = this.blueprintBaseUri;
+                const beforeLoadBlueprintBaseUri = this.embedFriendlyBlueprintBaseUri;
 
                 Promise.all([
                     this.loadTags(beforeLoadBlueprintBaseUri),
@@ -224,7 +243,7 @@
                     }
                 }).finally(() => {
                     // Handle switch tab while fetching data
-                    if (this.blueprintBaseUri === beforeLoadBlueprintBaseUri) {
+                    if (this.embedFriendlyBlueprintBaseUri === beforeLoadBlueprintBaseUri && callback) {
                         callback();
                     }
                 })
@@ -240,6 +259,14 @@
             ...mapState("plugin", ["icons"]),
             userCanCreateFlow() {
                 return this.user.hasAnyAction(permission.FLOW, action.CREATE);
+            },
+            embedFriendlyBlueprintBaseUri() {
+                const tab = this.tab ?? this?.$route?.params?.tab ?? "community";
+                let base = this.blueprintBaseUri;
+
+                return base
+                    ? (base.endsWith("/undefined") ? base.replace("/undefined", `/${tab}`) : base)
+                    : `${apiUrl(this.$store)}/blueprints/${tab}`;
             }
         },
         watch: {
@@ -273,13 +300,16 @@
                     this.load(this.onDataLoaded);
                 }
             },
-            blueprintBaseUri() {
-                this.hardReload();
-            },
             tags() {
                 if(!Object.prototype.hasOwnProperty.call(this.tags, this.selectedTag)) {
                     this.selectedTag = 0;
                 }
+            },
+            blueprintBaseUri() {
+                this.loadData();
+            },
+            tab() {
+                this.loadData()
             }
         }
     };

ui/src/stores/api.js

@@ -81,7 +81,7 @@ export default {
             }
         },
         pluginIcons(_, __) {
-            return axios.get(API_URL + "/v1/plugins/icons", {})
+            return axios.get(API_URL + "/v1/plugins/icons", {withCredentials: true})
         }
     },
     mutations: {

ui/src/stores/core.js

@@ -1,3 +1,5 @@
+import {apiUrl} from "override/utils/route";
+
 export default {
     namespaced: true,
     state: {
@@ -10,7 +12,8 @@ export default {
             template: undefined,
         },
         monacoYamlConfigured: false,
-        autocompletionSource: undefined
+        autocompletionSource: undefined,
+        tutorialFlows: []
     },
     actions: {
         showMessage({commit}, message) {
@@ -21,7 +24,10 @@ export default {
         },
         isUnsaved({commit}, unsavedChange) {
             commit("setUnsavedChange", unsavedChange)
-        }
+        },
+        readTutorialFlows({commit}) {
+            return this.$http.get(`${apiUrl(this)}/flows/tutorial`).then((response) => commit("setTutorialFlows", response.data))
+        },
     },
     mutations: {
         setMessage(state, message) {
@@ -41,7 +47,10 @@ export default {
         },
         setAutocompletionSource(state, autocompletionSource) {
             state.autocompletionSource = autocompletionSource
-        }
+        },
+        setTutorialFlows(state, flows) {
+            state.tutorialFlows = flows
+        },
     },
     getters: {
         unsavedChange(state) {