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): flaky consumer test (#10853)

Browse Source 
Co-authored-by: nKwiatkowski <nkwiatkowski@kestra.io>
This commit is contained in:
Nicolas K.
2025-08-22 09:37:43 +02:00
committed by GitHub
parent 88b0723147
commit c5341e56e9
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
script/src/test/java/io/kestra/plugin/scripts/runners/LogConsumerTest.java
View File

@@ -17,6 +17,7 @@ import io.kestra.plugin.scripts.runner.docker.Docker;
import io.kestra.core.junit.annotations.KestraTest; import io.kestra.core.junit.annotations.KestraTest;
import jakarta.inject.Inject; import jakarta.inject.Inject;
import jakarta.inject.Named; import jakarta.inject.Named;
import org.junit.jupiter.api.RepeatedTest;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.slf4j.event.Level; import org.slf4j.event.Level;
import reactor.core.publisher.Flux; import reactor.core.publisher.Flux;
@@ -116,7 +117,7 @@ class LogConsumerTest {
Collections.emptyList() Collections.emptyList()
); );
Await.until(() -> logs.size() >= 10, null, Duration.ofSeconds(10)); Await.until(() -> logs.size() >= 10, null, Duration.ofSeconds(20));
receive.blockLast(); receive.blockLast();
assertThat(logs.stream().filter(m -> m.getLevel().equals(Level.INFO)).count()).isEqualTo(1L); assertThat(logs.stream().filter(m -> m.getLevel().equals(Level.INFO)).count()).isEqualTo(1L);