chore(system): replace DSL.trueCondition by DSL.noCondition

jOOQ will then generates a query with no WHERE clause or no AND clause instead of WHERE true or WHERE 1=1

.github/workflows/main-build.yml

@@ -28,7 +28,7 @@ jobs:
     steps:
       # Targeting develop branch from develop
       - name: Trigger EE Workflow (develop push, no payload)
-        uses: peter-evans/repository-dispatch@5fc4efd1a4797ddb68ffd0714a238564e4cc0e6f
+        uses: peter-evans/repository-dispatch@28959ce8df70de7be546dd1250a005dd32156697
         if: ${{ github.event_name == 'push' && github.ref == 'refs/heads/develop' }}
         with:
           token: ${{ secrets.GH_PERSONAL_TOKEN }}

.github/workflows/pull-request.yml

@@ -16,7 +16,7 @@ jobs:
     - name: Check EE repo for branch with same name
       if: ${{ github.event_name == 'pull_request' && github.event.pull_request.head.repo.fork == false }}
       id: check-ee-branch
-      uses: actions/github-script@v7
+      uses: actions/github-script@v8
       with:
         github-token: ${{ secrets.GH_PERSONAL_TOKEN }}
         script: |
@@ -40,7 +40,7 @@ jobs:
 
       # Targeting pull request (only if not from a fork and EE has no branch with same name)
     - name: Trigger EE Workflow (pull request, with payload)
-      uses: peter-evans/repository-dispatch@5fc4efd1a4797ddb68ffd0714a238564e4cc0e6f
+      uses: peter-evans/repository-dispatch@28959ce8df70de7be546dd1250a005dd32156697
       if: ${{ github.event_name == 'pull_request'
         && github.event.pull_request.number != ''
         && github.event.pull_request.head.repo.fork == false
@@ -50,7 +50,7 @@ jobs:
         repository: kestra-io/kestra-ee
         event-type: "oss-updated"
         client-payload: >-
-          {"commit_sha":"${{ github.sha }}","pr_repo":"${{ github.repository }}"}
+          {"commit_sha":"${{ github.event.pull_request.head.sha }}","pr_repo":"${{ github.repository }}"}
 
   file-changes:
     if: ${{ github.event.pull_request.draft == false }}

build.gradle

@@ -7,7 +7,7 @@ buildscript {
     }
 
     dependencies {
-        classpath "net.e175.klaus:zip-prefixer:0.3.1"
+        classpath "net.e175.klaus:zip-prefixer:0.4.0"
     }
 }
 

cli/src/test/resources/application-test.yml

@@ -21,6 +21,7 @@ kestra:
   server:
     liveness:
       enabled: false
+    termination-grace-period: 5s
 micronaut:
   http:
     services:

core/src/test/resources/application-test.yml

@@ -58,7 +58,8 @@ kestra:
       purge:
         initial-delay: 1h
         fixed-delay: 1d
-        retention: 30d
+        retention: 30dPeriod
+    termination-grace-period: 5s
 
   anonymous-usage-report:
     enabled: false

core/src/test/resources/flows/valids/sleep-long.yml

@@ -4,7 +4,7 @@ namespace: io.kestra.tests
 tasks:
   - id: sleep-long
     type: io.kestra.plugin.core.flow.Sleep
-    duration: PT300S
+    duration: PT30S
 
 afterExecution:
   - id: output

executor/src/test/resources/application-test.yml

@@ -54,6 +54,7 @@ kestra:
         - "/api/v1/executions/webhook/"
     liveness:
       enabled: false
+    termination-grace-period: 5s
     service:
       purge:
         initial-delay: 1h

jdbc-h2/src/main/java/io/kestra/repository/h2/H2DashboardRepositoryService.java

@@ -16,6 +16,6 @@ public abstract class H2DashboardRepositoryService {
             conditions.add(jdbcRepository.fullTextCondition(List.of("fulltext"), query));
         }
 
-        return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 }

jdbc-h2/src/main/java/io/kestra/repository/h2/H2ExecutionRepositoryService.java

@@ -32,7 +32,7 @@ public abstract class H2ExecutionRepositoryService {
             });
         }
 
-        return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 
     public static Condition findLabelCondition(Either<Map<?, ?>, String> input, QueryFilter.Op operation) {
@@ -64,6 +64,6 @@ public abstract class H2ExecutionRepositoryService {
         if (!inConditions.isEmpty()) {
             conditions.add(DSL.or(inConditions));
         }
-        return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 }

jdbc-h2/src/main/java/io/kestra/repository/h2/H2FlowRepositoryService.java

@@ -31,7 +31,7 @@ public abstract class H2FlowRepositoryService {
             });
         }
 
-        return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 
     public static Condition findSourceCodeCondition(AbstractJdbcRepository<? extends FlowInterface> jdbcRepository, String query) {
@@ -54,6 +54,6 @@ public abstract class H2FlowRepositoryService {
             });
 
         }
-        return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 }

jdbc-h2/src/main/java/io/kestra/repository/h2/H2KvMetadataRepositoryService.java

@@ -16,6 +16,6 @@ public abstract class H2KvMetadataRepositoryService {
             conditions.add(jdbcRepository.fullTextCondition(List.of("fulltext"), query));
         }
 
-        return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 }

jdbc-h2/src/main/java/io/kestra/repository/h2/H2Repository.java

@@ -76,7 +76,7 @@ public class H2Repository<T> extends io.kestra.jdbc.AbstractJdbcRepository<T> {
 
     public Condition fullTextCondition(List<String> fields, String query) {
         if (query == null || query.equals("*")) {
-            return DSL.trueCondition();
+            return DSL.noCondition();
         }
 
         if (fields.size() > 1) {
@@ -105,12 +105,12 @@ public class H2Repository<T> extends io.kestra.jdbc.AbstractJdbcRepository<T> {
                         .sort(select, pageable)
                         .asTable("page")
                     )
-                    .where(DSL.trueCondition()),
+                    .where(DSL.noCondition()),
                 pageable
             )
             .fetch();
 
-        Integer totalCount = results.size() > 0 ? results.getFirst().get("total_count", Integer.class) : 0;
+        Integer totalCount = !results.isEmpty() ? results.getFirst().get("total_count", Integer.class) : 0;
 
         List<E> map = results
             .map((Record record) -> mapper.map((R) record));

jdbc-h2/src/test/resources/application-test.yml

@@ -19,6 +19,7 @@ kestra:
   server:
     liveness:
       enabled: false
+    termination-grace-period: 5s
     service:
       purge:
         initial-delay: 1h

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

@@ -17,6 +17,6 @@ public abstract class MysqlDashboardRepositoryService {
             conditions.add(jdbcRepository.fullTextCondition(Arrays.asList("title"), query));
         }
 
-        return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 }

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

@@ -27,7 +27,7 @@ public abstract class MysqlExecutionRepositoryService {
                 });
             }
 
-            return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+            return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 
     public static Condition findLabelCondition(Either<Map<?, ?>, String> input, QueryFilter.Op operation) {
@@ -63,7 +63,7 @@ public abstract class MysqlExecutionRepositoryService {
         if(!inConditions.isEmpty()){
             conditions.add(DSL.or(inConditions));
         }
-        return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 
 }

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

@@ -27,7 +27,7 @@ public abstract class MysqlFlowRepositoryService {
             });
         }
 
-        return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 
     public static Condition findSourceCodeCondition(AbstractJdbcRepository<? extends FlowInterface> jdbcRepository, String query) {
@@ -45,6 +45,6 @@ public abstract class MysqlFlowRepositoryService {
 
             });
         }
-        return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 }

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

@@ -16,6 +16,6 @@ public abstract class MysqlKvMetadataRepositoryService {
             conditions.add(jdbcRepository.fullTextCondition(List.of("name"), query));
         }
 
-        return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 }

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

@@ -43,7 +43,7 @@ public class MysqlRepository<T> extends AbstractJdbcRepository<T> {
     @Override
     public Condition fullTextCondition(List<String> fields, String query) {
         if (query == null || query.equals("*")) {
-            return DSL.trueCondition();
+            return DSL.noCondition();
         }
 
         String match = Arrays

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

@@ -33,7 +33,7 @@ public class MysqlTriggerRepository extends AbstractJdbcTriggerRepository {
 
     @Override
     protected Condition fullTextCondition(String query) {
-        return query == null ? DSL.trueCondition() : jdbcRepository.fullTextCondition(List.of("namespace", "flow_id", "trigger_id", "execution_id"), query);
+        return query == null ? DSL.noCondition() : jdbcRepository.fullTextCondition(List.of("namespace", "flow_id", "trigger_id", "execution_id"), query);
     }
 
     @Override

jdbc-mysql/src/test/resources/application-test.yml

@@ -25,6 +25,7 @@ kestra:
   server:
     liveness:
       enabled: false
+    termination-grace-period: 5s
     service:
       purge:
         initial-delay: 1h

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

@@ -17,6 +17,6 @@ public abstract class PostgresDashboardRepositoryService {
             conditions.add(jdbcRepository.fullTextCondition(Collections.singletonList("fulltext"), query));
         }
 
-        return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 }

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

@@ -26,7 +26,7 @@ public abstract class PostgresExecutionRepositoryService {
             });
         }
 
-        return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 
     public static Condition findLabelCondition(Either<Map<?, ?>, String> input, QueryFilter.Op operation) {
@@ -60,7 +60,7 @@ public abstract class PostgresExecutionRepositoryService {
         if (!inConditions.isEmpty()) {
             conditions.add(DSL.or(inConditions));
         }
-        return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 
     public static Condition statesFilter(List<State.Type> state) {

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

@@ -28,7 +28,7 @@ public abstract class PostgresFlowRepositoryService {
             });
         }
 
-        return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 
     public static Condition findSourceCodeCondition(AbstractJdbcRepository<? extends FlowInterface> jdbcRepository, String query) {
@@ -49,7 +49,7 @@ public abstract class PostgresFlowRepositoryService {
                 }
             });
         }
-        return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 
 

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

@@ -16,6 +16,6 @@ public abstract class PostgresKvMetadataRepositoryService {
             conditions.add(jdbcRepository.fullTextCondition(List.of("fulltext"), query));
         }
 
-        return conditions.isEmpty() ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.isEmpty() ? DSL.noCondition() : DSL.and(conditions);
     }
 }

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

@@ -42,7 +42,7 @@ public class PostgresRepository<T> extends io.kestra.jdbc.AbstractJdbcRepository
     @Override
     public Condition fullTextCondition(List<String> fields, String query) {
         if (query == null || query.equals("*")) {
-            return DSL.trueCondition();
+            return DSL.noCondition();
         }
 
         if (fields.size() > 1) {
@@ -106,7 +106,7 @@ public class PostgresRepository<T> extends io.kestra.jdbc.AbstractJdbcRepository
                     .sort(select, pageable)
                     .asTable("page")
                 )
-                .where(DSL.trueCondition()),
+                .where(DSL.noCondition()),
             pageable
         )
             .fetch();

jdbc-postgres/src/test/resources/application-test.yml

@@ -40,6 +40,7 @@ kestra:
   server:
     liveness:
       enabled: false
+    termination-grace-period: 5s
     service:
       purge:
         initial-delay: 1h

jdbc/src/main/java/io/kestra/jdbc/AbstractJdbcRepository.java

@@ -74,7 +74,7 @@ public abstract class AbstractJdbcRepository<T> {
             .of(io.kestra.jdbc.repository.AbstractJdbcRepository.field("value"), MAPPER.writeValueAsString(entity))
         );
     }
-    
+
     public int count(Condition condition) {
         return getDslContextWrapper()
             .transactionResult(configuration -> DSL
@@ -85,7 +85,7 @@ public abstract class AbstractJdbcRepository<T> {
                 .fetchOne(0, Integer.class)
             );
     }
-    
+
     public void persist(T entity) {
         this.persist(entity, null);
     }
@@ -223,8 +223,7 @@ public abstract class AbstractJdbcRepository<T> {
             .from(this
                 .sort(select, Pageable.from(Sort.of(Order.asc(orderField))))
                 .asTable("page")
-            )
-            .where(DSL.trueCondition());
+            );
     }
 
     @SneakyThrows

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

@@ -21,7 +21,7 @@ import java.util.stream.Stream;
  * NOTE: it uses the <code>defaultFilter(tenantId)</code> for querying.
  * If the child repository uses a default filter, it should override it.
  * <p>
- * For example, to avoid supporting allowDeleted:
+ * For example, to avoid supporting the <code>deleted</code> column:
  * <pre>{@code
  * @Override
  * protected Condition defaultFilter(String tenantId) {
@@ -30,7 +30,7 @@ import java.util.stream.Stream;
  *
  * @Override
  * protected Condition defaultFilter() {
- *     return DSL.trueCondition();
+ *     return DSL.noCondition();
  * }
  * }</pre>
  *

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

@@ -770,18 +770,16 @@ public abstract class AbstractJdbcExecutionRepository extends AbstractJdbcCrudRe
                     .from(this.jdbcRepository.getTable())
                     .where(this.defaultFilter(tenantId))
                     .and(NORMAL_KIND_CONDITION)
-                    .and(DSL.or(
-                        ListUtils.emptyOnNull(flows).isEmpty() ?
-                            DSL.trueCondition()
+                    .and(ListUtils.isEmpty(flows) ?
+                        DSL.noCondition()
                         :
-                            DSL.or(
-                                flows.stream()
-                                    .map(flow -> DSL.and(
-                                        field("namespace").eq(flow.getNamespace()),
-                                        field("flow_id").eq(flow.getId())
-                                    ))
-                                    .toList()
-                            )
+                        DSL.or(
+                            flows.stream()
+                                .map(flow -> DSL.and(
+                                    field("namespace").eq(flow.getNamespace()),
+                                    field("flow_id").eq(flow.getId())
+                                ))
+                                .toList()
                         )
                     );
 

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

@@ -55,7 +55,7 @@ public abstract class AbstractJdbcKvMetadataRepository extends AbstractJdbcCrudR
         boolean allowExpired,
         FetchVersion fetchBehavior
     ) {
-        var condition = allowExpired ? DSL.trueCondition() : DSL.or(
+        var condition = allowExpired ? DSL.noCondition() : DSL.or(
             field("expiration_date").greaterThan(Instant.now()),
             field("expiration_date").isNull());
 

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

@@ -34,12 +34,12 @@ public abstract class AbstractJdbcSettingRepository extends AbstractJdbcCrudRepo
 
     @Override
     public Optional<Setting> findByKey(String key) {
-        return findOne(DSL.trueCondition(), field("key").eq(key));
+        return findOne(DSL.noCondition(), field("key").eq(key));
     }
 
     @Override
     public List<Setting> findAll() {
-        return findAll(DSL.trueCondition());
+        return findAll(DSL.noCondition());
     }
 
     @Override
@@ -72,6 +72,6 @@ public abstract class AbstractJdbcSettingRepository extends AbstractJdbcCrudRepo
 
     @Override
     protected Condition defaultFilter() {
-        return DSL.trueCondition();
+        return DSL.noCondition();
     }
 }

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

@@ -64,7 +64,7 @@ public abstract class AbstractJdbcTemplateRepository extends AbstractJdbcCrudRep
     }
 
     private Condition computeCondition(@Nullable String query, @Nullable String namespace) {
-        Condition condition = DSL.trueCondition();
+        Condition condition = DSL.noCondition();
 
         if (query != null) {
             condition = condition.and(this.findCondition(query));

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

@@ -72,7 +72,7 @@ public abstract class AbstractJdbcTriggerRepository extends AbstractJdbcCrudRepo
 
     @Override
     public Optional<Trigger> findLast(TriggerContext trigger) {
-        return findOne(DSL.trueCondition(), field("key").eq(trigger.uid()));
+        return findOne(DSL.noCondition(), field("key").eq(trigger.uid()));
     }
 
     @Override
@@ -82,7 +82,7 @@ public abstract class AbstractJdbcTriggerRepository extends AbstractJdbcCrudRepo
 
     public List<Trigger> findByNextExecutionDateReadyForAllTenants(ZonedDateTime now, ScheduleContextInterface scheduleContextInterface) {
         JdbcSchedulerContext jdbcSchedulerContext = (JdbcSchedulerContext) scheduleContextInterface;
-        
+
         return jdbcSchedulerContext.getContext()
             .select(field("value"))
             .from(this.jdbcRepository.getTable())
@@ -98,9 +98,9 @@ public abstract class AbstractJdbcTriggerRepository extends AbstractJdbcCrudRepo
             .fetch()
             .map(r -> this.jdbcRepository.deserialize(r.get("value", String.class)));
     }
-    
+
     public List<Trigger> findByNextExecutionDateReadyButLockedTriggers(ZonedDateTime now) {
-        
+
         return this.jdbcRepository.getDslContextWrapper()
             .transactionResult(configuration -> DSL.using(configuration)
                 .select(field("value"))
@@ -115,7 +115,7 @@ public abstract class AbstractJdbcTriggerRepository extends AbstractJdbcCrudRepo
                 .fetch()
                 .map(r -> this.jdbcRepository.deserialize(r.get("value", String.class))));
     }
-    
+
     protected Temporal toNextExecutionTime(ZonedDateTime now) {
         return now.toOffsetDateTime();
     }
@@ -231,7 +231,7 @@ public abstract class AbstractJdbcTriggerRepository extends AbstractJdbcCrudRepo
     }
 
     protected Condition fullTextCondition(String query) {
-        return query == null ? DSL.trueCondition() : jdbcRepository.fullTextCondition(List.of("fulltext"), query);
+        return query == null ? DSL.noCondition() : jdbcRepository.fullTextCondition(List.of("fulltext"), query);
     }
 
     @Override
@@ -246,7 +246,7 @@ public abstract class AbstractJdbcTriggerRepository extends AbstractJdbcCrudRepo
 
     @Override
     protected Condition defaultFilter() {
-        return DSL.trueCondition();
+        return DSL.noCondition();
     }
 
     @Override

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

@@ -68,7 +68,7 @@ public abstract class JdbcFlowRepositoryService {
             });
         }
 
-        return conditions.size() == 0 ? DSL.trueCondition() : DSL.and(conditions);
+        return conditions.size() == 0 ? DSL.noCondition() : DSL.and(conditions);
     }
 
     public static Condition findSourceCodeCondition(AbstractJdbcRepository<Flow> jdbcRepository, String query) {

platform/build.gradle

@@ -17,10 +17,10 @@ dependencies {
     def mavenResolverVersion = "2.0.10"
     def jollydayVersion = "1.5.6"
     def jsonschemaVersion = "4.38.0"
-    def kafkaVersion = "4.1.0"
+    def kafkaVersion = "4.1.1"
     def opensearchVersion = "3.2.0"
     def opensearchRestVersion = "3.3.2"
-    def flyingSaucerVersion = "10.0.3"
+    def flyingSaucerVersion = "10.0.4"
     def jacksonVersion = "2.20.1"
     def jacksonAnnotationsVersion = "2.20"
     def jugVersion = "5.1.1"
@@ -31,11 +31,11 @@ dependencies {
     api enforcedPlatform("com.fasterxml.jackson:jackson-bom:$jacksonVersion")
     api enforcedPlatform("org.slf4j:slf4j-api:$slf4jVersion")
     api platform("io.micronaut.platform:micronaut-platform:4.9.4")
-    api platform("io.qameta.allure:allure-bom:2.30.0")
+    api platform("io.qameta.allure:allure-bom:2.31.0")
     // we define cloud bom here for GCP, Azure and AWS so they are aligned for all plugins that use them (secret, storage, oss and ee plugins)
-    api platform('com.google.cloud:libraries-bom:26.71.0')
+    api platform('com.google.cloud:libraries-bom:26.72.0')
     api platform("com.azure:azure-sdk-bom:1.3.2")
-    api platform('software.amazon.awssdk:bom:2.38.4')
+    api platform('software.amazon.awssdk:bom:2.38.9')
     api platform("dev.langchain4j:langchain4j-bom:$langchain4jVersion")
     api platform("dev.langchain4j:langchain4j-community-bom:$langchain4jCommunityVersion")
 
@@ -90,7 +90,7 @@ dependencies {
         api group: 'net.thisptr', name: 'jackson-jq', version: '1.6.0'
         api group: 'com.google.guava', name: 'guava', version: '33.4.8-jre'
         api group: 'commons-io', name: 'commons-io', version: '2.21.0'
-        api group: 'org.apache.commons', name: 'commons-lang3', version: '3.19.0'
+        api group: 'org.apache.commons', name: 'commons-lang3', version: '3.20.0'
         api 'ch.qos.logback.contrib:logback-json-classic:0.1.5'
         api 'ch.qos.logback.contrib:logback-jackson:0.1.5'
         api group: 'org.apache.maven.resolver', name: 'maven-resolver-impl', version: mavenResolverVersion
@@ -140,7 +140,7 @@ dependencies {
         api 'org.hamcrest:hamcrest:3.0'
         api 'org.hamcrest:hamcrest-library:3.0'
         api group: 'org.exparity', name: 'hamcrest-date', version: '2.0.8'
-        api "org.wiremock:wiremock-jetty12:3.13.1"
+        api "org.wiremock:wiremock-jetty12:3.13.2"
         api "org.apache.kafka:kafka-streams-test-utils:$kafkaVersion"
         api "com.microsoft.playwright:playwright:1.56.0"
         api "org.awaitility:awaitility:4.3.0"

repository-memory/src/test/resources/application-test.yml

@@ -9,4 +9,5 @@ kestra:
     poll-switch-interval: 5s
   server:
     liveness:
-      enabled: false
+      enabled: false
+    termination-grace-period: 5s

runner-memory/src/test/resources/application-test.yml

@@ -13,4 +13,5 @@ kestra:
     poll-switch-interval: 5s
   server:
     liveness:
-      enabled: false
+      enabled: false
+    termination-grace-period: 5s

scheduler/src/test/resources/application-test.yml

@@ -54,6 +54,7 @@ kestra:
         - "/api/v1/executions/webhook/"
     liveness:
       enabled: false
+    termination-grace-period: 5s
     service:
       purge:
         initial-delay: 1h

ui/package.json

@@ -38,8 +38,7 @@
         "cronstrue": "^3.9.0",
         "cytoscape": "^3.33.0",
         "dagre": "^0.8.5",
-        "el-table-infinite-scroll": "^3.0.7",
-        "element-plus": "2.11.7",
+        "element-plus": "2.11.8",
         "humanize-duration": "^3.33.1",
         "js-yaml": "^4.1.1",
         "lodash": "^4.17.21",
@@ -98,8 +97,8 @@
         "@types/testing-library__jest-dom": "^6.0.0",
         "@types/testing-library__user-event": "^4.2.0",
         "@typescript-eslint/parser": "^8.46.4",
-        "@vitejs/plugin-vue": "^6.0.1",
-        "@vitejs/plugin-vue-jsx": "^5.1.1",
+        "@vitejs/plugin-vue": "^6.0.2",
+        "@vitejs/plugin-vue-jsx": "^5.1.2",
         "@vitest/browser": "^3.2.4",
         "@vitest/coverage-v8": "^3.2.4",
         "@vue/eslint-config-prettier": "^10.2.0",
@@ -131,26 +130,23 @@
         "uuid": "^13.0.0",
         "vite": "npm:rolldown-vite@latest",
         "vitest": "^3.2.4",
-        "vue-tsc": "^3.1.3"
+        "vue-tsc": "^3.1.4"
     },
     "optionalDependencies": {
         "@esbuild/darwin-arm64": "^0.27.0",
         "@esbuild/darwin-x64": "^0.27.0",
         "@esbuild/linux-x64": "^0.27.0",
-        "@rollup/rollup-darwin-arm64": "^4.53.2",
-        "@rollup/rollup-darwin-x64": "^4.53.2",
-        "@rollup/rollup-linux-x64-gnu": "^4.53.2",
-        "@swc/core-darwin-arm64": "^1.15.1",
-        "@swc/core-darwin-x64": "^1.15.1",
-        "@swc/core-linux-x64-gnu": "^1.15.1"
+        "@rollup/rollup-darwin-arm64": "^4.53.3",
+        "@rollup/rollup-darwin-x64": "^4.53.3",
+        "@rollup/rollup-linux-x64-gnu": "^4.53.3",
+        "@swc/core-darwin-arm64": "^1.15.2",
+        "@swc/core-darwin-x64": "^1.15.2",
+        "@swc/core-linux-x64-gnu": "^1.15.2"
     },
     "overrides": {
         "bootstrap": {
             "@popperjs/core": "npm:@sxzz/popperjs-es@^2.11.7"
         },
-        "el-table-infinite-scroll": {
-            "vue": "^3.5.21"
-        },
         "storybook": "$storybook",
         "vite": "npm:rolldown-vite@latest"
     },

ui/src/components/layout/SelectTable.vue

@@ -19,7 +19,7 @@
 </template>
 
 <script setup lang="ts">
-    import {ref, onMounted, onUnmounted, onUpdated, watch, withDefaults} from "vue";
+    import {ref, onMounted, onUnmounted, onUpdated, watch} from "vue";
 
     const props = withDefaults(defineProps<{
         showSelection?: boolean;

webserver/src/test/resources/application-test.yml

@@ -172,6 +172,7 @@ kestra:
         - "/api/v1/main/executions/webhook/"
     liveness:
       enabled: false
+    termination-grace-period: 5s
     service:
       purge:
         initial-delay: 1h

worker/src/test/resources/application-test.yml

@@ -54,6 +54,7 @@ kestra:
         - "/api/v1/executions/webhook/"
     liveness:
       enabled: false
+    termination-grace-period: 5s
     service:
       purge:
         initial-delay: 1h