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): better error message on AbstractRunnerTest.concurrencyQueueRestarted

Browse Source
This commit is contained in:
brian.mulier
2025-11-26 12:35:24 +01:00
committed by brian-mulier-p
parent 9f90412237
commit e37e2b0166
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
core/src/test/java/io/kestra/core/runners/FlowConcurrencyCaseTest.java
View File

@@ -13,7 +13,6 @@ import io.kestra.core.queues.QueueInterface;
import io.kestra.core.repositories.FlowRepositoryInterface;
import io.kestra.core.services.ExecutionService;
import io.kestra.core.storages.StorageInterface;
import io.kestra.core.utils.TestsUtils;
import jakarta.inject.Inject;
import jakarta.inject.Named;
import jakarta.inject.Singleton;
@@ -171,8 +170,9 @@ public class FlowConcurrencyCaseTest {
assertThat(executionResult1.getState().getCurrent()).isEqualTo(Type.FAILED);
// it should have been queued after restarted
assertThat(executionResult1.getState().getHistories().stream().anyMatch(history -> history.getState() == Type.RESTARTED)).isTrue();
assertThat(executionResult1.getState().getHistories().stream().anyMatch(history -> history.getState() == Type.QUEUED)).isTrue();
List<Type> stateList = executionResult1.getState().getHistories().stream().map(History::getState).toList();
assertThat(stateList).contains(Type.RESTARTED);
assertThat(stateList).contains(Type.QUEUED);
assertThat(executionResult2.getState().getCurrent()).isEqualTo(Type.FAILED);
assertThat(executionResult2.getState().getHistories().getFirst().getState()).isEqualTo(State.Type.CREATED);
assertThat(executionResult2.getState().getHistories().get(1).getState()).isEqualTo(State.Type.QUEUED);