WIP

.github/workflows/main-build.yml

@@ -64,7 +64,6 @@ jobs:
       DOCKERHUB_USERNAME: ${{ secrets.DOCKERHUB_USERNAME }}
       DOCKERHUB_PASSWORD: ${{ secrets.DOCKERHUB_PASSWORD }}
       SLACK_WEBHOOK_URL: ${{ secrets.SLACK_WEBHOOK_URL }}
-      GH_PERSONAL_TOKEN: ${{ secrets.GH_PERSONAL_TOKEN }}
 
 
   publish-develop-maven:

.github/workflows/release-docker.yml

@@ -32,4 +32,3 @@ jobs:
       DOCKERHUB_USERNAME: ${{ secrets.DOCKERHUB_USERNAME }}
       DOCKERHUB_PASSWORD: ${{ secrets.DOCKERHUB_PASSWORD }}
       SLACK_WEBHOOK_URL: ${{ secrets.SLACK_WEBHOOK_URL }}
-      GH_PERSONAL_TOKEN: ${{ secrets.GH_PERSONAL_TOKEN }}

build.gradle

@@ -21,7 +21,7 @@ plugins {
 
     // test
     id "com.adarshr.test-logger" version "4.0.0"
-    id "org.sonarqube" version "7.2.0.6526"
+    id "org.sonarqube" version "7.1.0.6387"
     id 'jacoco-report-aggregation'
 
     // helper
@@ -223,13 +223,13 @@ subprojects {subProj ->
             t.environment 'ENV_TEST2', "Pass by env"
 
 
-//            if (subProj.name == 'core' || subProj.name == 'jdbc-h2' || subProj.name == 'jdbc-mysql' || subProj.name == 'jdbc-postgres') {
-//                // JUnit 5 parallel settings
-//                t.systemProperty 'junit.jupiter.execution.parallel.enabled', 'true'
-//                t.systemProperty 'junit.jupiter.execution.parallel.mode.default', 'concurrent'
-//                t.systemProperty 'junit.jupiter.execution.parallel.mode.classes.default', 'same_thread'
-//                t.systemProperty 'junit.jupiter.execution.parallel.config.strategy', 'dynamic'
-//            }
+            if (subProj.name == 'core' || subProj.name == 'jdbc-h2' || subProj.name == 'jdbc-mysql' || subProj.name == 'jdbc-postgres') {
+                // JUnit 5 parallel settings
+                t.systemProperty 'junit.jupiter.execution.parallel.enabled', 'true'
+                t.systemProperty 'junit.jupiter.execution.parallel.mode.default', 'concurrent'
+                t.systemProperty 'junit.jupiter.execution.parallel.mode.classes.default', 'same_thread'
+                t.systemProperty 'junit.jupiter.execution.parallel.config.strategy', 'dynamic'
+            }
         }
 
         tasks.register('flakyTest', Test) { Test t ->

cli/src/main/java/io/kestra/cli/commands/migrations/metadata/MetadataMigrationService.java

@@ -24,7 +24,6 @@ import java.time.Instant;
 import java.util.*;
 import java.util.function.Function;
 import java.util.stream.Collectors;
-import java.util.stream.Stream;
 
 import static io.kestra.core.utils.Rethrow.throwConsumer;
 import static io.kestra.core.utils.Rethrow.throwFunction;
@@ -37,15 +36,11 @@ public class MetadataMigrationService {
     protected KvMetadataRepositoryInterface kvMetadataRepository;
     protected NamespaceFileMetadataRepositoryInterface namespaceFileMetadataRepository;
     protected StorageInterface storageInterface;
-    protected NamespaceUtils namespaceUtils;
 
     @VisibleForTesting
     public Map<String, List<String>> namespacesPerTenant() {
         String tenantId = tenantService.resolveTenant();
-        return Map.of(tenantId, Stream.concat(
-            Stream.of(namespaceUtils.getSystemFlowNamespace()),
-            flowRepository.findDistinctNamespace(tenantId).stream()
-        ).map(NamespaceUtils::asTree).flatMap(Collection::stream).distinct().toList());
+        return Map.of(tenantId, flowRepository.findDistinctNamespace(tenantId).stream().map(NamespaceUtils::asTree).flatMap(Collection::stream).distinct().toList());
     }
 
     public void kvMigration() throws IOException {

cli/src/main/java/io/kestra/cli/commands/sys/statestore/StateStoreMigrateCommand.java

@@ -57,7 +57,7 @@ public class StateStoreMigrateCommand extends AbstractCommand {
             String taskRunValue = statesUriPart.length > 2 ? statesUriPart[1] : null;
             String stateSubName = statesUriPart[statesUriPart.length - 1];
             boolean flowScoped = flowQualifierWithStateQualifiers[0].endsWith("/" + flow.getId());
-            StateStore stateStore = new StateStore(runContextFactory.of(flow, Map.of()), false);
+            StateStore stateStore = new StateStore(runContext(runContextFactory, flow), false);
 
             try (InputStream is = storageInterface.get(flow.getTenantId(), flow.getNamespace(), stateStoreFileUri)) {
                 stateStore.putState(flowScoped, stateName, stateSubName, taskRunValue, is.readAllBytes());
@@ -70,4 +70,12 @@ public class StateStoreMigrateCommand extends AbstractCommand {
         stdOut("Successfully ran the state-store migration.");
         return 0;
     }
+
+    private RunContext runContext(RunContextFactory runContextFactory, Flow flow) {
+        Map<String, String> flowVariables = new HashMap<>();
+        flowVariables.put("tenantId", flow.getTenantId());
+        flowVariables.put("id", flow.getId());
+        flowVariables.put("namespace", flow.getNamespace());
+        return runContextFactory.of(flow, Map.of("flow", flowVariables));
+    }
 }

cli/src/test/java/io/kestra/cli/commands/migrations/metadata/MetadataMigrationServiceTest.java

@@ -10,15 +10,12 @@ import org.mockito.Mockito;
 import java.util.Collection;
 import java.util.List;
 import java.util.Map;
-import java.util.stream.Stream;
 
 import static org.assertj.core.api.Assertions.assertThat;
 
 public class MetadataMigrationServiceTest<T extends MetadataMigrationService> {
     private static final String TENANT_ID = TestsUtils.randomTenant();
 
-    protected static final String SYSTEM_NAMESPACE = "my.system.namespace";
-
     @Test
     void namespacesPerTenant() {
         Map<String, List<String>> expected = getNamespacesPerTenant();
@@ -27,13 +24,8 @@ public class MetadataMigrationServiceTest<T extends MetadataMigrationService> {
         ).namespacesPerTenant();
 
         assertThat(result).hasSize(expected.size());
-        expected.forEach((tenantId, namespaces) -> {
-            assertThat(result.get(tenantId)).containsExactlyInAnyOrderElementsOf(
-                Stream.concat(
-                    Stream.of(SYSTEM_NAMESPACE),
-                    namespaces.stream()
-                ).map(NamespaceUtils::asTree).flatMap(Collection::stream).distinct().toList()
-            );
+        expected.forEach((tenantId, namespaces) -> {;
+            assertThat(result.get(tenantId)).containsExactlyInAnyOrderElementsOf(namespaces.stream().map(NamespaceUtils::asTree).flatMap(Collection::stream).distinct().toList());
         });
     }
 
@@ -44,14 +36,12 @@ public class MetadataMigrationServiceTest<T extends MetadataMigrationService> {
     protected T metadataMigrationService(Map<String, List<String>> namespacesPerTenant) {
         FlowRepositoryInterface mockedFlowRepository = Mockito.mock(FlowRepositoryInterface.class);
         Mockito.doAnswer((params) -> namespacesPerTenant.get(params.getArgument(0).toString())).when(mockedFlowRepository).findDistinctNamespace(Mockito.anyString());
-        NamespaceUtils namespaceUtils = Mockito.mock(NamespaceUtils.class);
-        Mockito.when(namespaceUtils.getSystemFlowNamespace()).thenReturn(SYSTEM_NAMESPACE);
         //noinspection unchecked
         return ((T) new MetadataMigrationService(mockedFlowRepository, new TenantService() {
             @Override
             public String resolveTenant() {
                 return TENANT_ID;
             }
-        }, null, null, null, namespaceUtils));
+        }, null, null, null));
     }
 }

cli/src/test/java/io/kestra/cli/commands/sys/statestore/StateStoreMigrateCommandTest.java

@@ -55,7 +55,11 @@ class StateStoreMigrateCommandTest {
             );
             assertThat(storage.exists(tenantId, flow.getNamespace(), oldStateStoreUri)).isTrue();
 
-            RunContext runContext = ctx.getBean(RunContextFactory.class).of(flow, Map.of());
+            RunContext runContext = ctx.getBean(RunContextFactory.class).of(flow, Map.of("flow", Map.of(
+                "tenantId", tenantId,
+                "id", flow.getId(),
+                "namespace", flow.getNamespace()
+            )));
             StateStore stateStore = new StateStore(runContext, true);
             Assertions.assertThrows(MigrationRequiredException.class, () -> stateStore.getState(true, "my-state", "sub-name", "my-taskrun-value"));
 

core/src/main/java/io/kestra/core/models/Label.java

@@ -4,16 +4,13 @@ import io.kestra.core.utils.MapUtils;
 import io.swagger.v3.oas.annotations.media.Schema;
 import jakarta.annotation.Nullable;
 import jakarta.validation.constraints.NotEmpty;
-import jakarta.validation.constraints.Pattern;
 
 import java.util.*;
 import java.util.function.Predicate;
 import java.util.stream.Collectors;
 
 @Schema(description = "A key/value pair that can be attached to a Flow or Execution. Labels are often used to organize and categorize objects.")
-public record Label(
-        @NotEmpty @Pattern(regexp = "^[\\p{Ll}][\\p{L}0-9._-]*$", message = "Invalid label key. A valid key contains only lowercase letters numbers hyphens (-) underscores (_) or periods (.) and must begin with a lowercase letter.") String key,
-        @NotEmpty String value) {
+public record Label(@NotEmpty String key, @NotEmpty String value) {
     public static final String SYSTEM_PREFIX = "system.";
 
     // system labels

core/src/main/java/io/kestra/core/models/QueryFilter.java

@@ -94,7 +94,7 @@ public record QueryFilter(
         KIND("kind") {
             @Override
             public List<Op> supportedOp() {
-                return List.of(Op.EQUALS,Op.NOT_EQUALS, Op.IN, Op.NOT_IN);
+                return List.of(Op.EQUALS,Op.NOT_EQUALS);
             }
         },
         LABELS("labels") {
@@ -106,7 +106,7 @@ public record QueryFilter(
         FLOW_ID("flowId") {
             @Override
             public List<Op> supportedOp() {
-                return List.of(Op.EQUALS, Op.NOT_EQUALS, Op.CONTAINS, Op.STARTS_WITH, Op.ENDS_WITH, Op.REGEX, Op.IN, Op.NOT_IN, Op.PREFIX);
+                return List.of(Op.EQUALS, Op.NOT_EQUALS, Op.CONTAINS, Op.STARTS_WITH, Op.ENDS_WITH, Op.REGEX);
             }
         },
         UPDATED("updated") {
@@ -226,7 +226,7 @@ public record QueryFilter(
         FLOW {
             @Override
             public List<Field> supportedField() {
-                return List.of(Field.LABELS, Field.NAMESPACE, Field.QUERY, Field.SCOPE, Field.FLOW_ID);
+                return List.of(Field.LABELS, Field.NAMESPACE, Field.QUERY, Field.SCOPE);
             }
         },
         NAMESPACE {
@@ -241,7 +241,7 @@ public record QueryFilter(
                 return List.of(
                     Field.QUERY, Field.SCOPE, Field.FLOW_ID, Field.START_DATE, Field.END_DATE,
                     Field.STATE, Field.LABELS, Field.TRIGGER_EXECUTION_ID, Field.CHILD_FILTER,
-                    Field.NAMESPACE, Field.KIND
+                    Field.NAMESPACE,Field.KIND
                 );
             }
         },

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

@@ -267,10 +267,6 @@ public class State {
             return this == Type.RUNNING || this == Type.KILLING;
         }
 
-        public boolean onlyRunning() {
-            return this == Type.RUNNING;
-        }
-
         public boolean isFailed() {
             return this == Type.FAILED;
         }

core/src/main/java/io/kestra/core/models/property/Property.java

@@ -93,7 +93,7 @@ public class Property<T> {
      * @return a new {@link Property} without a pre-rendered value
      */
     public Property<T> skipCache() {
-        return new Property<>(expression, true);
+        return Property.ofExpression(expression);
     }
 
     /**

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

@@ -158,7 +158,11 @@ public class FlowInputOutput {
                             File tempFile = File.createTempFile(prefix, fileExtension);
                             try (var inputStream = fileUpload.getInputStream();
                                  var outputStream = new FileOutputStream(tempFile)) {
-                                inputStream.transferTo(outputStream);
+                                long transferredBytes = inputStream.transferTo(outputStream);
+                                if (transferredBytes == 0) {
+                                    sink.error(new KestraRuntimeException("Can't upload file: " + fileUpload.getFilename()));
+                                    return;
+                                }
                                 URI from = storageInterface.from(execution, inputId, fileName, tempFile);
                                 sink.next(Map.entry(inputId, from.toString()));
                             } finally {
@@ -378,11 +382,11 @@ public class FlowInputOutput {
 
     @SuppressWarnings("unchecked")
     private static <T> Object resolveDefaultPropertyAs(Input<?> input, PropertyContext renderer, Class<T> clazz) throws IllegalVariableEvaluationException {
-        return Property.as((Property<T>) input.getDefaults().skipCache(), renderer, clazz);
+        return Property.as((Property<T>) input.getDefaults(), renderer, clazz);
     }
     @SuppressWarnings("unchecked")
     private static <T> Object resolveDefaultPropertyAsList(Input<?> input, PropertyContext renderer, Class<T> clazz) throws IllegalVariableEvaluationException {
-        return Property.asList((Property<List<T>>) input.getDefaults().skipCache(), renderer, clazz);
+        return Property.asList((Property<List<T>>) input.getDefaults(), renderer, clazz);
     }
 
     private RunContext buildRunContextForExecutionAndInputs(final FlowInterface flow, final Execution execution, Map<String, InputAndValue> dependencies, final boolean decryptSecrets) {
@@ -498,8 +502,8 @@ public class FlowInputOutput {
                         yield storageInterface.from(execution, id, current.toString().substring(current.toString().lastIndexOf("/") + 1), new File(current.toString()));
                     }
                 }
-                case JSON -> (current instanceof Map || current instanceof Collection<?>) ? current :  JacksonMapper.toObject(current.toString());
-                case YAML -> (current instanceof Map || current instanceof Collection<?>) ? current : YAML_MAPPER.readValue(current.toString(), JacksonMapper.OBJECT_TYPE_REFERENCE);
+                case JSON -> JacksonMapper.toObject(current.toString());
+                case YAML -> YAML_MAPPER.readValue(current.toString(), JacksonMapper.OBJECT_TYPE_REFERENCE);
                 case URI -> {
                     Matcher matcher = URI_PATTERN.matcher(current.toString());
                     if (matcher.matches()) {

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

@@ -171,16 +171,14 @@ public class RunContextFactory {
             .build();
     }
 
+
+    @VisibleForTesting
     public RunContext of(final FlowInterface flow, final Map<String, Object> variables) {
         RunContextLogger runContextLogger = new RunContextLogger();
         return newBuilder()
             .withLogger(runContextLogger)
             .withStorage(new InternalStorage(runContextLogger.logger(), StorageContext.forFlow(flow), storageInterface, namespaceService, namespaceFactory))
-            .withVariables(newRunVariablesBuilder()
-                .withFlow(flow)
-                .withVariables(variables)
-                .build(runContextLogger, PropertyContext.create(this.variableRenderer))
-            )
+            .withVariables(variables)
             .withSecretInputs(secretInputsFromFlow(flow))
             .build();
     }

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

@@ -160,7 +160,7 @@ public class RunnerUtils {
             executionEmitter.run();
 
             if (duration == null) {
-                Await.until(() -> receive.get() != null, Duration.ofMillis(10));
+                Await.untilWithSleepInterval(() -> receive.get() != null, Duration.ofMillis(10));
             } else {
                 Await.until(() -> receive.get() != null, Duration.ofMillis(10), duration);
             }

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

@@ -2,7 +2,6 @@ package io.kestra.core.runners.pebble;
 
 import io.kestra.core.runners.VariableRenderer;
 import io.kestra.core.runners.pebble.functions.RenderingFunctionInterface;
-import io.micrometer.core.instrument.MeterRegistry;
 import io.micronaut.context.ApplicationContext;
 import io.micronaut.core.annotation.Nullable;
 import io.pebbletemplates.pebble.PebbleEngine;
@@ -19,37 +18,35 @@ import java.util.stream.Collectors;
 
 @Singleton
 public class PebbleEngineFactory {
-
+    
     private final ApplicationContext applicationContext;
     private final VariableRenderer.VariableConfiguration variableConfiguration;
-    private final MeterRegistry meterRegistry;
-
+    
     @Inject
-    public PebbleEngineFactory(ApplicationContext applicationContext, @Nullable VariableRenderer.VariableConfiguration variableConfiguration, MeterRegistry meterRegistry) {
+    public PebbleEngineFactory(ApplicationContext applicationContext, @Nullable VariableRenderer.VariableConfiguration variableConfiguration) {
         this.applicationContext = applicationContext;
         this.variableConfiguration = variableConfiguration;
-        this.meterRegistry = meterRegistry;
     }
-
+    
     public PebbleEngine create() {
         PebbleEngine.Builder builder = newPebbleEngineBuilder();
         this.applicationContext.getBeansOfType(Extension.class).forEach(builder::extension);
         return builder.build();
     }
-
+    
     public PebbleEngine createWithMaskedFunctions(VariableRenderer renderer, final List<String> functionsToMask) {
-
+        
         PebbleEngine.Builder builder = newPebbleEngineBuilder();
-
+        
         this.applicationContext.getBeansOfType(Extension.class).stream()
             .map(e -> functionsToMask.stream().anyMatch(fun -> e.getFunctions().containsKey(fun))
                 ? extensionWithMaskedFunctions(renderer, e, functionsToMask)
                 : e)
             .forEach(builder::extension);
-
+        
         return builder.build();
     }
-
+    
     private PebbleEngine.Builder newPebbleEngineBuilder() {
         PebbleEngine.Builder builder = new PebbleEngine.Builder()
             .registerExtensionCustomizer(ExtensionCustomizer::new)
@@ -57,15 +54,13 @@ public class PebbleEngineFactory {
             .cacheActive(this.variableConfiguration.getCacheEnabled())
             .newLineTrimming(false)
             .autoEscaping(false);
-
+        
         if (this.variableConfiguration.getCacheEnabled()) {
-            PebbleLruCache cache = new PebbleLruCache(this.variableConfiguration.getCacheSize());
-            cache.register(meterRegistry);
-            builder = builder.templateCache(cache);
+            builder = builder.templateCache(new PebbleLruCache(this.variableConfiguration.getCacheSize()));
         }
         return builder;
     }
-
+    
     private Extension extensionWithMaskedFunctions(VariableRenderer renderer, Extension initialExtension, List<String> maskedFunctions) {
         return (Extension) Proxy.newProxyInstance(
             initialExtension.getClass().getClassLoader(),
@@ -79,16 +74,16 @@ public class PebbleEngineFactory {
                             } else if (RenderingFunctionInterface.class.isAssignableFrom(entry.getValue().getClass())) {
                                 return Map.entry(entry.getKey(), this.variableRendererProxy(renderer, entry.getValue()));
                             }
-
+                            
                             return entry;
                         }).collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
                 }
-
+                
                 return method.invoke(initialExtension, methodArgs);
             }
         );
     }
-
+    
     private Function variableRendererProxy(VariableRenderer renderer, Function initialFunction) {
         return (Function) Proxy.newProxyInstance(
             initialFunction.getClass().getClassLoader(),
@@ -101,7 +96,7 @@ public class PebbleEngineFactory {
             }
         );
     }
-
+    
     private Function maskedFunctionProxy(Function initialFunction) {
         return (Function) Proxy.newProxyInstance(
             initialFunction.getClass().getClassLoader(),

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

@@ -1,29 +1,29 @@
 package io.kestra.core.runners.pebble;
 
-import com.github.benmanes.caffeine.cache.Cache;
-import com.github.benmanes.caffeine.cache.Caffeine;
-import io.micrometer.core.instrument.MeterRegistry;
-import io.micrometer.core.instrument.binder.cache.CaffeineCacheMetrics;
+import com.google.common.cache.Cache;
+import com.google.common.cache.CacheBuilder;
 import io.pebbletemplates.pebble.cache.PebbleCache;
 import io.pebbletemplates.pebble.template.PebbleTemplate;
+import lombok.extern.slf4j.Slf4j;
 
+import java.util.concurrent.ExecutionException;
 import java.util.function.Function;
 
+@Slf4j
 public class PebbleLruCache implements PebbleCache<Object, PebbleTemplate> {
-    private final Cache<Object, PebbleTemplate> cache;
+    Cache<Object, PebbleTemplate> cache;
 
     public PebbleLruCache(int maximumSize) {
-        cache = Caffeine.newBuilder()
+        cache = CacheBuilder.newBuilder()
             .initialCapacity(250)
             .maximumSize(maximumSize)
-            .recordStats()
             .build();
     }
 
     @Override
     public PebbleTemplate computeIfAbsent(Object key, Function<? super Object, ? extends PebbleTemplate> mappingFunction) {
         try {
-            return cache.get(key, mappingFunction);
+            return cache.get(key, () -> mappingFunction.apply(key));
         } catch (Exception e) {
             // we retry the mapping function in order to let the exception be thrown instead of being capture by cache
             return mappingFunction.apply(key);
@@ -34,8 +34,4 @@ public class PebbleLruCache implements PebbleCache<Object, PebbleTemplate> {
     public void invalidateAll() {
         cache.invalidateAll();
     }
-
-    public void register(MeterRegistry meterRegistry) {
-        CaffeineCacheMetrics.monitor(meterRegistry, cache, "pebble-template");
-    }
 }

core/src/main/java/io/kestra/core/serializers/ListOrMapOfLabelDeserializer.java

@@ -26,14 +26,7 @@ public class ListOrMapOfLabelDeserializer extends JsonDeserializer<List<Label>>
         else if (p.hasToken(JsonToken.START_ARRAY)) {
             // deserialize as list
             List<Map<String, String>> ret = ctxt.readValue(p, List.class);
-            return ret.stream().map(map -> {
-                Object value = map.get("value");
-                if (isAllowedType(value)) {
-                    return new Label(map.get("key"), String.valueOf(value));
-                } else {
-                    throw new IllegalArgumentException("Unsupported type for key: " + map.get("key") + ", value: " + value);
-                }
-            }).toList();
+            return ret.stream().map(map -> new Label(map.get("key"), map.get("value"))).toList();
         }
         else if (p.hasToken(JsonToken.START_OBJECT)) {
             // deserialize as map

core/src/main/java/io/kestra/core/utils/Await.java

@@ -6,18 +6,18 @@ import java.util.concurrent.atomic.AtomicReference;
 import java.util.function.BooleanSupplier;
 import java.util.function.Supplier;
 
-/**
- * @deprecated use {@link org.awaitility.Awaitility} instead
- */
-@Deprecated
 public class Await {
     private static final Duration defaultSleep = Duration.ofMillis(100);
 
     public static void until(BooleanSupplier condition) {
-        Await.until(condition, null);
+        Await.untilWithSleepInterval(condition, null);
     }
 
-    public static void until(BooleanSupplier condition, Duration sleep) {
+    public static void untilWithTimeout(BooleanSupplier condition, Duration timeout) throws TimeoutException {
+        until(condition, null, timeout);
+    }
+
+    public static void untilWithSleepInterval(BooleanSupplier condition, Duration sleep) {
         if (sleep == null) {
             sleep = defaultSleep;
         }
@@ -78,10 +78,10 @@ public class Await {
         return result.get();
     }
 
-    public static <T> T until(Supplier<T> supplier, Duration sleep) {
+    public static <T> T untilWithSleepInterval(Supplier<T> supplier, Duration sleep) {
         AtomicReference<T> result = new AtomicReference<>();
 
-        Await.until(untilSupplier(supplier, result), sleep);
+        Await.untilWithSleepInterval(untilSupplier(supplier, result), sleep);
 
         return result.get();
     }

core/src/main/java/io/kestra/core/utils/ListUtils.java

@@ -65,9 +65,10 @@ public class ListUtils {
     }
 
     public static List<String> convertToListString(Object object){
-        return convertToList(object)
-            .stream()
-            .map(Object::toString)
-            .toList();
+        if (object instanceof List<?> list && (list.isEmpty() || list.getFirst() instanceof String)) {
+            return (List<String>) list;
+        } else {
+            throw new IllegalArgumentException("%s in not an instance of List of String".formatted(object));
+        }
     }
 }

core/src/main/java/io/kestra/core/utils/NamespaceFilesUtils.java

@@ -32,12 +32,10 @@ public class NamespaceFilesUtils {
     private ExecutorsUtils executorsUtils;
 
     private ExecutorService executorService;
-    private int maxThreads;
 
     @PostConstruct
     public void postConstruct() {
-        this.maxThreads = Math.max(Runtime.getRuntime().availableProcessors() * 4, 32);
-        this.executorService = executorsUtils.maxCachedThreadPool(maxThreads, "namespace-file");
+        this.executorService = executorsUtils.maxCachedThreadPool(Math.max(Runtime.getRuntime().availableProcessors() * 4, 32), "namespace-file");
     }
 
     public void loadNamespaceFiles(
@@ -65,11 +63,7 @@ public class NamespaceFilesUtils {
           matchedNamespaceFiles.addAll(files);
         }
 
-        // Use half of the available threads to avoid impacting concurrent tasks
-        int parallelism = maxThreads / 2;
         Flux.fromIterable(matchedNamespaceFiles)
-            .parallel(parallelism)
-            .runOn(Schedulers.fromExecutorService(executorService))
             .doOnNext(throwConsumer(nsFile -> {
                 InputStream content = runContext.storage().getFile(nsFile.uri());
                 Path path = folderPerNamespace ?
@@ -77,7 +71,7 @@ public class NamespaceFilesUtils {
                     Path.of(nsFile.path());
                 runContext.workingDir().putFile(path, content, fileExistComportment);
             }))
-            .sequential()
+            .publishOn(Schedulers.fromExecutorService(executorService))
             .blockLast();
 
         Duration duration = stopWatch.getDuration();

core/src/main/java/io/kestra/core/utils/Rethrow.java

@@ -1,7 +1,10 @@
 package io.kestra.core.utils;
 
+import lombok.extern.slf4j.Slf4j;
+
 import java.util.function.*;
 
+@Slf4j
 public final class Rethrow {
     @FunctionalInterface
     public interface ConsumerChecked<T, E extends Exception> {
@@ -117,4 +120,17 @@ public final class Rethrow {
     private static <E extends Exception, R> R throwException(Exception exception) throws E {
         throw (E) exception;
     }
+
+    public static <T> Consumer<T> failAwareConsumer(Consumer<T> consumer, boolean failSilently) {
+        return t -> {
+            try {
+                consumer.accept(t);
+            } catch (Exception exception) {
+                if (!failSilently) {
+                    throw exception;
+                }
+                log.warn("Suppressed exception from consumer", exception);
+            }
+        };
+    }
 }

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

@@ -157,7 +157,7 @@ public class LoopUntil extends Task implements FlowableTask<LoopUntil.Output> {
 
     public Instant nextExecutionDate(RunContext runContext, Execution execution, TaskRun parentTaskRun) throws IllegalVariableEvaluationException {
         if (!this.reachedMaximums(runContext, execution, parentTaskRun, false)) {
-            String continueLoop = runContext.render(this.condition).skipCache().as(String.class).orElse(null);
+            String continueLoop = runContext.render(this.condition).as(String.class).orElse(null);
             if (!TruthUtils.isTruthy(continueLoop)) {
                 return Instant.now().plus(runContext.render(this.getCheckFrequency().getInterval()).as(Duration.class).orElseThrow());
             }

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

@@ -123,7 +123,7 @@ public class Switch extends Task implements FlowableTask<Switch.Output> {
     }
 
     private String rendererValue(RunContext runContext) throws IllegalVariableEvaluationException {
-        return runContext.render(this.value).skipCache().as(String.class).orElseThrow();
+        return runContext.render(this.value).as(String.class).orElseThrow();
     }
 
     @Override

core/src/main/java/io/kestra/plugin/core/templating/TemplatedTask.java

@@ -32,17 +32,9 @@ import lombok.experimental.SuperBuilder;
     examples = {
         @Example(
             code = """
-                id: templated_task
-                namespace: company.team
-                variables:
-                  property: uri
-                  value: https://kestra.io
-                tasks:
-                  - id: templated_task
-                    type: io.kestra.plugin.core.templating.TemplatedTask
-                    spec: |
-                      type: io.kestra.plugin.core.http.Download
-                      {{ vars.property }}: {{ vars.value }}
+                spec: |
+                  type: io.kestra.plugin.core.http.Download
+                  {{ task.property }}: {{ task.value }}
                 """
         )
     },

core/src/main/resources/icons/io.kestra.plugin.core.condition.DayWeekCondition.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-288 -326)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.condition.DayWeekInMonthCondition.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-288 -606)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.condition.ExecutionFlowCondition.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-624 -606)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.condition.ExecutionNamespaceCondition.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-736 -606)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.condition.ExecutionStatusCondition.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-848 -606)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.condition.FlowCondition.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-400 -326)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.condition.FlowNamespaceCondition.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-512 -326)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.condition.HasRetryAttemptCondition.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-624 -326)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.condition.MultipleCondition.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-736 -326)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.condition.NotCondition.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-848 -326)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.condition.OrCondition.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-960 -326)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.condition.TimeBetweenCondition.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1072 -326)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.condition.VariableCondition.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1184 -326)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.condition.WeekendCondition.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-400 -606)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.condition.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-512 -606)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.dashboard.chart.Bar.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1520 -326)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.dashboard.chart.Markdown.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1632 -326)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.dashboard.chart.Pie.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1744 -326)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.dashboard.chart.Table.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1296 -466)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.dashboard.chart.TimeSeries.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1408 -466)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.dashboard.chart.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1520 -466)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.dashboard.data.Executions.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1632 -466)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.dashboard.data.Logs.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-64 -606)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.dashboard.data.Metrics.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1744 -466)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.dashboard.data.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-176 -606)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.debug.Return.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1408 -326)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.debug.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1296 -326)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.execution.Counts.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1520 -886)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.execution.Fail.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1408 -886)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.execution.PurgeExecutions.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1632 -886)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.execution.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1744 -886)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.flow.AllowFailure.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-288 -466)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.flow.Dag.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-176 -466)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.flow.EachParallel.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-400 -466)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.flow.EachSequential.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-624 -466)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.flow.Flow.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-64 -466)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.flow.If.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1184 -466)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.flow.Parallel.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-512 -466)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.flow.Sequential.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-736 -466)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.flow.Switch.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-848 -466)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.flow.Template.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-960 -466)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.flow.WorkingDirectory.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1072 -466)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.flow.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-64 -466)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.http.Download.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-176 -746)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.http.Request.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-288 -746)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.http.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-64 -746)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.kv.Get.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1408 -606)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.kv.GetKeys.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1520 -606)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.kv.Set.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1632 -606)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.kv.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1744 -606)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.log.Fetch.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-960 -606)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.log.Log.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1072 -606)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.log.PurgeLogs.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1184 -606)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.log.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1296 -606)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.metric.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-400 -746)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.namespace.DeleteFiles.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-736 -746)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.namespace.DownloadFiles.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-848 -746)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.namespace.UploadFiles.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-960 -746)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.namespace.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1072 -746)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.output.OutputValues.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-624 -746)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.output.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-512 -746)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.runner.Process.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1296 -746)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.runner.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1184 -746)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.state.Delete.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1408 -746)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.state.Get.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1520 -746)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.state.Set.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1632 -746)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.state.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-1744 -746)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.storage.Concat.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-64 -886)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.storage.Delete.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-176 -886)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.storage.Reverse.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-288 -886)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.storage.Size.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-512 -886)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.storage.Split.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-624 -886)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.storage.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-400 -886)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.templating.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-736 -886)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.trigger.Flow.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-848 -886)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>

core/src/main/resources/icons/io.kestra.plugin.core.trigger.Schedule.svg

@@ -1,7 +1,7 @@
 <svg width="80" height="80" viewBox="0 0 80 80" fill="none" xmlns="http://www.w3.org/2000/svg">
-
+<rect width="80" height="80" fill="#F2F2F2"/>
 <g filter="url(#filter0_ii_0_1)">
-
+<rect width="1936" height="1336" transform="translate(-960 -886)" fill="white"/>
 <g filter="url(#filter1_i_0_1)">
 <path d="M0 20C0 8.95431 8.95431 0 20 0H60C71.0457 0 80 8.95431 80 20V60C80 71.0457 71.0457 80 60 80H20C8.95431 80 0 71.0457 0 60V20Z" fill="url(#paint0_linear_0_1)"/>
 </g>