diff --git a/jdbc-mysql/src/main/java/io/kestra/repository/mysql/MysqlExecutionRepository.java b/jdbc-mysql/src/main/java/io/kestra/repository/mysql/MysqlExecutionRepository.java index c5f015d5793..ed4dfcba550 100644 --- a/jdbc-mysql/src/main/java/io/kestra/repository/mysql/MysqlExecutionRepository.java +++ b/jdbc-mysql/src/main/java/io/kestra/repository/mysql/MysqlExecutionRepository.java @@ -20,6 +20,6 @@ public MysqlExecutionRepository(ApplicationContext applicationContext, AbstractJ @Override protected Condition findCondition(String query) { - return this.jdbcRepository.fullTextCondition(Arrays.asList("namespace", "id"), query); + return this.jdbcRepository.fullTextCondition(Arrays.asList("namespace", "flow_id", "id"), query); } }