chore: update version to v0.18.5

When we send a 404 status by retuning HttpReponse.notFound(), the webhook hang forever for POST request (but works for GET).

Throwing an HttpStatusException fix the issue, it seems to be caused by a bug in Micronaut, I will try to create a reproducer and open an issue upstream by meanwhile this fixes the issue.

.github/dependabot.yml

@@ -22,12 +22,20 @@ 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"
+      day: "sunday"
+      time: "09:00"
+    open-pull-requests-limit: 50
     labels:
       - "dependency-upgrade"
-    open-pull-requests-limit: 50
+    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

@@ -117,10 +117,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 +277,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 +369,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

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/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/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/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);

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/log/PurgeLogs.java

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

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/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)

gradle.properties

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

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/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/AbstractJdbcLogRepository.java

@@ -441,7 +441,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 +493,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/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/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.2",
   "private": true,
-  "packageManager": "npm@9.8.1",
+  "type": "module",
+  "packageManager": "npm@9.9.3",
   "scripts": {
     "dev": "vite --host",
     "build": "vite build --emptyOutDir",
@@ -12,17 +13,17 @@
     "lint": "eslint . --ext .vue,.js,.jsx,.cjs,.mjs --fix"
   },
   "dependencies": {
-    "@kestra-io/ui-libs": "^0.0.53",
+    "@kestra-io/ui-libs": "^0.0.57",
     "@vue-flow/background": "^1.3.0",
     "@vue-flow/controls": "^1.1.2",
-    "@vue-flow/core": "^1.39.1",
+    "@vue-flow/core": "^1.39.3",
     "ansi-to-html": "^0.7.2",
-    "axios": "^1.7.2",
+    "axios": "^1.7.3",
     "bootstrap": "^5.3.3",
     "buffer": "^6.0.3",
     "chart.js": "^4.4.3",
     "chartjs-chart-treemap": "^2.3.1",
-    "core-js": "^3.37.1",
+    "core-js": "^3.38.0",
     "cronstrue": "^2.50.0",
     "dagre": "^0.8.5",
     "element-plus": "^2.7.8",
@@ -39,20 +40,18 @@
     "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",
+    "posthog-js": "^1.154.5",
     "throttle-debounce": "^5.0.2",
-    "vite-plugin-eslint": "^1.8.1",
-    "vue": "^3.4.34",
+    "vue": "^3.4.36",
     "vue-axios": "3.5.2",
     "vue-chartjs": "^5.3.1",
     "vue-gtag": "^2.0.1",
     "vue-i18n": "^9.13.1",
     "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",
@@ -62,10 +61,11 @@
     "yaml": "^2.5.0"
   },
   "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.12.1",
+    "@typescript-eslint/parser": "^8.0.1",
+    "@vitejs/plugin-vue": "^5.1.2",
     "@vue/eslint-config-prettier": "^9.0.0",
     "@vue/test-utils": "^2.4.6",
     "decompress": "^4.2.1",
@@ -77,13 +77,14 @@
     "prettier": "^3.3.3",
     "rollup-plugin-copy": "^3.5.0",
     "rollup-plugin-visualizer": "^5.12.0",
-    "sass": "^1.77.4",
+    "sass": "^1.77.8",
     "typescript": "^5.5.4",
     "vite": "^5.3.5",
-    "vitest": "^2.0.4"
+    "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.20.0"
   },
   "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/executions/Executions.vue

@@ -106,6 +106,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 +125,7 @@
                 </el-form-item>
             </template>
 
-            <template #top v-if="isDisplayedTop">
+            <template #top v-if="showStatChart()">
                 <state-global-chart
                     v-if="daily"
                     class="mb-4"
@@ -493,6 +500,7 @@
                 dblClickRouteName: "executions/update",
                 flowTriggerDetails: undefined,
                 recomputeInterval: false,
+                showChart: ["true", null].includes(localStorage.getItem(storageKeys.SHOW_CHART)),
                 optionalColumns: [
                     {
                         label: "start date",
@@ -568,7 +576,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 +648,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 +694,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 +786,7 @@
             },
             deleteExecutions() {
                 const includeNonTerminated = ref(false);
-                
+
                 const deleteLogs = ref(true);
                 const deleteMetrics = ref(true);
                 const deleteStorage = ref(true);
@@ -784,7 +805,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/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/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/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 {
@@ -262,6 +262,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 +329,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;

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/MonacoEditor.vue

@@ -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,7 +56,7 @@
                         </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>                     
                     </el-button>
@@ -153,8 +153,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"
@@ -279,6 +279,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/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/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

@@ -39,7 +39,7 @@
                     <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}, query: {tab}}"
                     >
                         <div class="left">
                             <div>
@@ -72,7 +72,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-if="userCanCreateFlow" size="large" text bg @click.prevent.stop="blueprintToEditor(blueprint.id)">
                                 {{ $t('use') }}
                             </el-button>
                         </div>
@@ -108,6 +108,10 @@
                 type: String,
                 required: true
             },
+            tab: {
+                type: String,
+                default: undefined,
+            },
             embed: {
                 type: Boolean,
                 default: false
@@ -146,7 +150,7 @@
                     params: {
                         tenant: this.$route.params.tenant
                     },
-                    query: {blueprintId: blueprintId}
+                    query: {blueprintId: blueprintId, blueprintSource: this.blueprintBaseUri.includes("community") ? "community" : "custom"}
                 });
             },
             tagsToString(blueprintTags) {
@@ -224,7 +228,7 @@
                     }
                 }).finally(() => {
                     // Handle switch tab while fetching data
-                    if (this.blueprintBaseUri === beforeLoadBlueprintBaseUri) {
+                    if (this.blueprintBaseUri === beforeLoadBlueprintBaseUri && callback) {
                         callback();
                     }
                 })
@@ -273,9 +277,6 @@
                     this.load(this.onDataLoaded);
                 }
             },
-            blueprintBaseUri() {
-                this.hardReload();
-            },
             tags() {
                 if(!Object.prototype.hasOwnProperty.call(this.tags, this.selectedTag)) {
                     this.selectedTag = 0;

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) {

ui/src/translations/en.json

@@ -633,6 +633,7 @@
         "MAIN": "Parent Executions"
       }
     },
+    "show chart": "Show Chart",
     "namespace files": {
       "toggle": {
         "show": "Show namespace files",
@@ -790,6 +791,7 @@
       "previous": "Previous",
       "finish": "Finish",
       "skip": "Skip Tutorial",
+      "no_flows": "No flows available under tutorial namespace.",
       "steps": {
         "0": {
           "title": "Welcome to Kestra!",

ui/src/translations/fr.json

@@ -767,6 +767,7 @@
       "previous": "Précédent",
       "finish": "Finir",
       "skip": "Passer le tutoriel",
+      "no_flows": "Aucun flux disponible dans l'espace de noms du tutoriel.",
       "steps": {
         "0": {
           "title": "Bienvenue chez Kestra!",

ui/src/utils/charts.js

@@ -74,7 +74,7 @@ export function chartClick(moment, router, route, event) {
     const query = {};
 
     if (event.date) {
-        const formattedDate = moment(event.date, "DD/MM/YYYY");
+        const formattedDate = moment(event.date, moment.localeData().longDateFormat("L"));
         query.startDate = formattedDate.toISOString(true);
         query.endDate = formattedDate.add(1, "d").toISOString(true);
     }

ui/src/utils/constants.js

@@ -1,6 +1,7 @@
 export const SECTIONS = {
     TASKS: "TASKS",
     TRIGGERS: "TRIGGERS",
+    TASK_RUNNERS: "TASK_RUNNERS",
 }
 
 export const stateGlobalChartTypes = {
@@ -29,6 +30,7 @@ export const storageKeys = {
     DISPLAY_FLOW_EXECUTIONS_COLUMNS: "displayFlowExecutionsColumns",
     SELECTED_TENANT: "selectedTenant",
     EXECUTE_FLOW_BEHAVIOUR: "executeFlowBehaviour",
+    SHOW_CHART: "showChart",
     DEFAULT_NAMESPACE: "defaultNamespace",
     LATEST_NAMESPACE: "latestNamespace",
     PAGINATION_SIZE: "paginationSize",

ui/src/utils/init.js

@@ -3,7 +3,7 @@ import {createRouter, createWebHistory} from "vue-router";
 import VueGtag from "vue-gtag";
 import {createI18n} from "vue-i18n";
 import moment from "moment-timezone";
-import "moment/locale/fr"
+import "moment/dist/locale/fr"
 import {extendMoment} from "moment-range";
 import VueSidebarMenu from "vue-sidebar-menu";
 import {
@@ -50,6 +50,7 @@ import TaskSubflowInputs from "../components/flows/tasks/TaskSubflowInputs.vue";
 import LeftMenuLink from "../components/LeftMenuLink.vue";
 import RouterMd from "../components/utils/RouterMd.vue";
 import Utils from "./utils";
+import TaskTaskRunner from "../components/flows/tasks/TaskTaskRunner.vue";
 
 export default (app, routes, stores, translations) => {
     // charts
@@ -151,6 +152,7 @@ export default (app, routes, stores, translations) => {
     app.component("TaskSubflowNamespace", TaskSubflowNamespace)
     app.component("TaskSubflowId", TaskSubflowId)
     app.component("TaskSubflowInputs", TaskSubflowInputs)
+    app.component("TaskTaskRunner", TaskTaskRunner)
     app.component("LeftMenuLink", LeftMenuLink)
     app.component("RouterMd", RouterMd)
 

ui/src/utils/markdown.js

@@ -3,49 +3,43 @@ import mark from "markdown-it-mark";
 import meta from "markdown-it-meta";
 import anchor from "markdown-it-anchor";
 import container from "markdown-it-container";
-import {fromHighlighter} from "@shikijs/markdown-it/core"
-import {getHighlighterCore} from "shiki/core"
+import {fromHighlighter} from "@shikijs/markdown-it/core";
+import {createHighlighterCore} from "shiki/core";
 import githubDark from "shiki/themes/github-dark.mjs";
 import githubLight from "shiki/themes/github-light.mjs";
 import {linkTag} from "./markdown_plugins/link";
 
+let highlighter = null;
+
+async function getHighlighter() {
+    if (!highlighter) {
+        highlighter = createHighlighterCore({
+            langs: [import("shiki/langs/yaml.mjs"), import("shiki/langs/python.mjs"), import("shiki/langs/javascript.mjs")],
+            themes: [githubDark, githubLight],
+            loadWasm: import("shiki/wasm"),
+        });
+    }
+    return highlighter;
+}
+
 export default class Markdown {
     static async render(markdown, options) {
+        const highlighter = await getHighlighter();
+
         githubDark["colors"]["editor.background"] = "var(--bs-gray-500)";
         githubLight["colors"]["editor.background"] = "var(--bs-white)";
 
-        const highlighter = await getHighlighterCore({
-            themes: [
-                githubDark,
-                githubLight
-            ],
-            langs: [
-                import("shiki/langs/yaml.mjs"),
-                import("shiki/langs/python.mjs"),
-                import("shiki/langs/javascript.mjs")
-            ],
-            loadWasm: import("shiki/wasm")
-        })
-
-        options = options || {}
+        options = options || {};
 
         const darkTheme = document.getElementsByTagName("html")[0].className.indexOf("dark") >= 0;
 
-        // noinspection JSPotentiallyInvalidConstructorUsage
-        let md = new markdownIt() // jshint ignore:line
+        let md = new markdownIt()
             .use(mark)
             .use(meta)
-            .use(anchor, {
-                permalink: options.permalink ? anchor.permalink.ariaHidden({
-                    placement: "before"
-                }) : undefined
-            })
-            // if more alert types are used inside the task documentation, they need to be configured here also
+            .use(anchor, {permalink: options.permalink ? anchor.permalink.ariaHidden({placement: "before"}) : undefined})
             .use(container, "warning")
             .use(container, "info")
-            .use(fromHighlighter(highlighter, {
-                theme: darkTheme ? "github-dark" : "github-light",
-            }))
+            .use(fromHighlighter(highlighter, {theme: darkTheme ? "github-dark" : "github-light"}))
             .use(linkTag);
 
         md.set({
@@ -56,12 +50,10 @@ export default class Markdown {
             typographer: true,
             langPrefix: "language-",
             quotes: "“”‘’",
-        })
+        });
 
-        md.renderer.rules.table_open = () => "<table class=\"table\">\n"
+        md.renderer.rules.table_open = () => "<table class=\"table\">\n";
 
-        return md.render(
-            markdown
-        );
+        return md.render(markdown);
     }
 }

ui/vite.config.js

@@ -3,9 +3,10 @@ import {defineConfig} from "vite";
 import vue from "@vitejs/plugin-vue";
 import {visualizer} from "rollup-plugin-visualizer";
 import eslintPlugin from "vite-plugin-eslint";
+import * as sass from "sass"
 
 import {filename} from "./plugins/filename"
-import {details} from "./plugins/details"
+import {commit} from "./plugins/commit"
 
 export default defineConfig({
     base: "",
@@ -22,16 +23,18 @@ export default defineConfig({
     plugins: [
         vue(),
         visualizer(),
-        eslintPlugin({
-            failOnWarning: true,
-            failOnError: true
-        }),
+        eslintPlugin({failOnWarning: true, failOnError: true}),
         filename(),
-        details()
+        commit()
     ],
     assetsInclude: ["**/*.md"],
     css: {
-        devSourcemap: true
+        devSourcemap: true,
+        preprocessorOptions: {
+            scss: {
+                logger: sass.Logger.silent
+            },
+        }
     },
     optimizeDeps: {
         include: [

webserver/src/main/java/io/kestra/webserver/controllers/ErrorController.java

@@ -13,6 +13,7 @@ import io.micronaut.http.HttpStatus;
 import io.micronaut.http.annotation.Controller;
 import io.micronaut.http.annotation.Error;
 import io.micronaut.http.client.exceptions.HttpClientResponseException;
+import io.micronaut.http.exceptions.HttpStatusException;
 import io.micronaut.http.hateoas.JsonError;
 import io.micronaut.http.hateoas.Link;
 import io.micronaut.web.router.exceptions.UnsatisfiedBodyRouteException;
@@ -138,6 +139,11 @@ public class ErrorController {
         return jsonError(request, e, HttpStatus.UNPROCESSABLE_ENTITY, "Invalid route params");
     }
 
+    @Error(global = true)
+    public HttpResponse<JsonError> error(HttpRequest<?> request, HttpStatusException e) {
+        return jsonError(request, e, e.getStatus(), e.getStatus().getReason());
+    }
+
     @Error(global = true)
     public HttpResponse<JsonError> error(HttpRequest<?> request, Throwable e) {
         return jsonError(request, e, HttpStatus.INTERNAL_SERVER_ERROR, "Internal server error");

webserver/src/main/java/io/kestra/webserver/controllers/api/ExecutionController.java

@@ -56,6 +56,7 @@ import io.micronaut.http.sse.Event;
 import io.micronaut.scheduling.TaskExecutors;
 import io.micronaut.scheduling.annotation.ExecuteOn;
 import io.micronaut.validation.Validated;
+import io.netty.util.IllegalReferenceCountException;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.media.Content;
@@ -458,7 +459,7 @@ public class ExecutionController {
         HttpRequest<String> request
     ) {
         if (maybeFlow.isEmpty()) {
-            return HttpResponse.notFound();
+            throw new HttpStatusException(HttpStatus.NOT_FOUND, "Flow not found");
         }
 
         var flow = maybeFlow.get();
@@ -489,13 +490,13 @@ public class ExecutionController {
             .findFirst();
 
         if (webhook.isEmpty()) {
-            return HttpResponse.notFound();
+            throw new HttpStatusException(HttpStatus.NOT_FOUND, "Webhook not found");
         }
 
         Optional<Execution> execution = webhook.get().evaluate(request, flow);
 
         if (execution.isEmpty()) {
-            return HttpResponse.notFound();
+            throw new HttpStatusException(HttpStatus.NOT_FOUND, "No execution triggered");
         }
 
         var result = execution.get();
@@ -588,13 +589,21 @@ public class ExecutionController {
                                 sink.success(item);
                             }
                         });
-                        sink.onDispose(() -> receive.run());
+
+                        sink.onDispose(receive::run);
                     }
                 } catch (IOException e) {
                     sink.error(new RuntimeException(e));
                 }
             })
-            .doOnError(t -> Flux.from(inputs).subscribeOn(Schedulers.boundedElastic()).blockLast()); // need to consume the inputs in case of error;
+            .doOnError(t -> {
+                // need to consume the inputs in case of error, that can failed, but we ignored
+                try {
+                    Flux.from(inputs).subscribeOn(Schedulers.boundedElastic()).blockLast();
+                } catch (IllegalReferenceCountException ignored) {
+
+                }
+            });
     }
 
     private List<Label> parseLabels(List<String> labels) {

webserver/src/main/java/io/kestra/webserver/controllers/api/LogController.java

@@ -126,7 +126,7 @@ public class LogController {
         @Parameter(description = "The min log level filter") @Nullable @QueryValue Level minLevel
     ) {
         AtomicReference<Runnable> cancel = new AtomicReference<>();
-        List<String> levels = LogEntry.findLevelsByMin(minLevel);
+        List<String> levels = LogEntry.findLevelsByMin(minLevel).stream().map(level -> level.name()).toList();
 
         return Flux
             .<Event<LogEntry>>create(emitter -> {

webserver/src/test/java/io/kestra/webserver/controllers/api/ExecutionControllerTest.java

@@ -131,6 +131,7 @@ class ExecutionControllerTest extends JdbcH2ControllerTest {
             Execution.class
         );
     }
+
     private MultipartBody createInputsFlowBody() {
         // Trigger execution
         File applicationFile = new File(Objects.requireNonNull(
@@ -188,6 +189,25 @@ class ExecutionControllerTest extends JdbcH2ControllerTest {
         assertThat(notFound.getStatus(), is(HttpStatus.NOT_FOUND));
     }
 
+
+    @Test
+    void invalidInputs() {
+        MultipartBody.Builder builder = MultipartBody.builder()
+            .addPart("validatedString", "B-failed");
+        inputs.forEach((s, o) -> builder.addPart(s, o instanceof String ? (String) o : null));
+
+        HttpClientResponseException e = assertThrows(
+            HttpClientResponseException.class,
+            () -> triggerExecution(TESTS_FLOW_NS, "inputs", builder.build(), false)
+        );
+
+        String response = e.getResponse().getBody(String.class).orElseThrow();
+
+        assertThat(response, containsString("Invalid entity"));
+        assertThat(response, containsString("Invalid input for `validatedString`"));
+    }
+
+
     @Test
     void triggerAndWait() {
         Execution result = triggerInputsFlowExecution(true);
@@ -697,6 +717,70 @@ class ExecutionControllerTest extends JdbcH2ControllerTest {
 
     }
 
+    @Test
+    void webhookFlowNotFound() {
+        HttpClientResponseException exception = assertThrows(HttpClientResponseException.class,
+            () -> client.toBlocking().retrieve(
+                HttpRequest
+                    .POST(
+                        "/api/v1/executions/webhook/not-found/webhook/not-found?name=john&age=12&age=13",
+                        ImmutableMap.of("a", 1, "b", true)
+                    ),
+                Execution.class
+            )
+        );
+        assertThat(exception.getStatus(), is(HttpStatus.NOT_FOUND));
+        assertThat(exception.getMessage(), containsString("Not Found: Flow not found"));
+
+        exception = assertThrows(HttpClientResponseException.class,
+            () -> client.toBlocking().retrieve(
+                HttpRequest
+                    .PUT(
+                        "/api/v1/executions/webhook/not-found/webhook/not-found?name=john&age=12&age=13",
+                        Collections.singletonList(ImmutableMap.of("a", 1, "b", true))
+                    ),
+                Execution.class
+            )
+        );
+        assertThat(exception.getStatus(), is(HttpStatus.NOT_FOUND));
+        assertThat(exception.getMessage(), containsString("Not Found: Flow not found"));
+
+        exception = assertThrows(HttpClientResponseException.class,
+            () -> client.toBlocking().retrieve(
+                HttpRequest
+                    .POST(
+                        "/api/v1/executions/webhook/not-found/webhook/not-found?name=john&age=12&age=13",
+                        "bla"
+                    ),
+                Execution.class
+            )
+        );
+        assertThat(exception.getStatus(), is(HttpStatus.NOT_FOUND));
+        assertThat(exception.getMessage(), containsString("Not Found: Flow not found"));
+
+        exception = assertThrows(HttpClientResponseException.class,
+            () -> client.toBlocking().retrieve(
+                GET("/api/v1/executions/webhook/not-found/webhook/not-found?name=john&age=12&age=13"),
+                Execution.class
+            )
+        );
+        assertThat(exception.getStatus(), is(HttpStatus.NOT_FOUND));
+        assertThat(exception.getMessage(), containsString("Not Found: Flow not found"));
+
+        exception = assertThrows(HttpClientResponseException.class,
+            () -> client.toBlocking().retrieve(
+                HttpRequest
+                    .POST(
+                        "/api/v1/executions/webhook/not-found/webhook/not-found?name=john&age=12&age=13",
+                        "{\\\"a\\\":\\\"\\\",\\\"b\\\":{\\\"c\\\":{\\\"d\\\":{\\\"e\\\":\\\"\\\",\\\"f\\\":\\\"1\\\"}}}}"
+                    ),
+                Execution.class
+            )
+        );
+        assertThat(exception.getStatus(), is(HttpStatus.NOT_FOUND));
+        assertThat(exception.getMessage(), containsString("Not Found: Flow not found"));
+    }
+
     @Test
     void webhookDynamicKey() {
         Execution execution = client.toBlocking().retrieve(