jprdonnelly/kestra
1
0
Fork 0
mirror of https://github.com/kestra-io/kestra.git synced 2025-12-19 18:05:41 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix(tests): larger timeout for JdbcServiceLivenessCoordinatorTest.shouldReEmitTasksToTheSameWorkerGroup

Browse Source
This commit is contained in:
brian.mulier
2025-11-27 15:43:47 +01:00
committed by brian-mulier-p
parent 65786343ef
commit b68dcb7bf5
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
jdbc-mysql/src/test/java/io/kestra/runner/mysql/MySqlJdbcDeserializationIssuesTest.java → jdbc-mysql/src/test/java/io/kestra/runner/mysql/MysqlJdbcDeserializationIssuesTest.java
View File

@@ -2,5 +2,5 @@ package io.kestra.runner.mysql;
import io.kestra.jdbc.runner.AbstractJdbcDeserializationIssuesTest;
class MySqlJdbcDeserializationIssuesTest extends AbstractJdbcDeserializationIssuesTest {
class MysqlJdbcDeserializationIssuesTest extends AbstractJdbcDeserializationIssuesTest {
}

2
jdbc/src/test/java/io/kestra/jdbc/runner/JdbcServiceLivenessCoordinatorTest.java
View File

@@ -164,7 +164,7 @@ public abstract class JdbcServiceLivenessCoordinatorTest {
// create second worker (this will revoke previously one).
Worker newWorker = applicationContext.createBean(TestMethodScopedWorker.class, IdUtils.create(), 1, "workerGroupKey");
newWorker.run();
boolean resubmitLatchAwait = resubmitLatch.await(10, TimeUnit.SECONDS);
boolean resubmitLatchAwait = resubmitLatch.await(30, TimeUnit.SECONDS);
assertThat(resubmitLatchAwait)
.withFailMessage(() -> "shouldReEmitTasksToTheSameWorkerGroup: resubmitLatchAwait was not OK, workerTaskResultQueue content: " + TestsUtils.stringify(workerTaskResultQueueAppendLog))
.isTrue();