From 79faf91250e1011e2a80895d7b3d60517e58d176 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lo=C3=AFc=20Mathieu?= Date: Mon, 19 Jan 2026 15:54:34 +0100 Subject: [PATCH] chore(system): compilation issue --- .../kestra/jdbc/runner/AbstractJdbcConcurrencyLimitStorage.java | 2 +- .../kestra/jdbc/runner/AbstractJdbcExecutionQueuedStorage.java | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/jdbc/src/main/java/io/kestra/jdbc/runner/AbstractJdbcConcurrencyLimitStorage.java b/jdbc/src/main/java/io/kestra/jdbc/runner/AbstractJdbcConcurrencyLimitStorage.java index 5d73a2fa01e..093ce66bed3 100644 --- a/jdbc/src/main/java/io/kestra/jdbc/runner/AbstractJdbcConcurrencyLimitStorage.java +++ b/jdbc/src/main/java/io/kestra/jdbc/runner/AbstractJdbcConcurrencyLimitStorage.java @@ -113,7 +113,7 @@ public void decrementAndPop(FlowInterface flow, AbstractJdbcExecutionQueuedStora int newLimit = fetchOne(dslContext, flow).map( concurrencyLimit -> { int decremented = concurrencyLimit.getRunning() == 0 ? 0 : concurrencyLimit.getRunning() - 1; - update(dslContext, concurrencyLimit.withRunning(decremented)); + save(dslContext, concurrencyLimit.withRunning(decremented)); return decremented; } ).orElse(0); diff --git a/jdbc/src/main/java/io/kestra/jdbc/runner/AbstractJdbcExecutionQueuedStorage.java b/jdbc/src/main/java/io/kestra/jdbc/runner/AbstractJdbcExecutionQueuedStorage.java index 4d9de59632a..76fe724741a 100644 --- a/jdbc/src/main/java/io/kestra/jdbc/runner/AbstractJdbcExecutionQueuedStorage.java +++ b/jdbc/src/main/java/io/kestra/jdbc/runner/AbstractJdbcExecutionQueuedStorage.java @@ -15,6 +15,7 @@ import java.util.function.BiConsumer; public abstract class AbstractJdbcExecutionQueuedStorage extends AbstractJdbcRepository { + protected static final Field VALUE_FIELD = field("value", String.class); protected io.kestra.jdbc.AbstractJdbcRepository jdbcRepository; public AbstractJdbcExecutionQueuedStorage(io.kestra.jdbc.AbstractJdbcRepository jdbcRepository) {