fix(queue): change index to remove a sort

2025-12-25 11:12:12 -05:00 · 2025-12-08 17:06:21 +01:00
1 changed files with 1 additions and 1 deletions
--- a/jdbc-mysql/src/main/java/io/kestra/runner/mysql/MysqlQueue.java
+++ b/jdbc-mysql/src/main/java/io/kestra/runner/mysql/MysqlQueue.java
@@ -36,7 +36,7 @@ public class MysqlQueue<T> extends JdbcQueue<T> {
                AbstractJdbcRepository.field("offset")
            )
            // force using the dedicated index, or it made a scan of the PK index
-            .from(this.table.useIndex("ix_type__consumers"))
+            .from(this.table.useIndex("ix_type__offset"))
            .where(AbstractJdbcRepository.field("type").eq(queueType()))
            .and(DSL.or(List.of(
                AbstractJdbcRepository.field("consumers").isNull(),