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): mark LogConsumerTest.logs() as flaky

Browse Source
This commit is contained in:
Loïc Mathieu
2025-10-17 09:54:31 +02:00
parent 0a13d378f4
commit abe1509ccf
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -2,6 +2,7 @@ package io.kestra.plugin.scripts.runners;
import com.google.common.collect.ImmutableMap;
import io.kestra.core.context.TestRunContextFactory;
import io.kestra.core.junit.annotations.FlakyTest;
import io.kestra.core.models.executions.LogEntry;
import io.kestra.core.models.property.Property;
import io.kestra.core.models.tasks.runners.TaskCommands;
@@ -96,6 +97,7 @@ class LogConsumerTest {
}
@Test
@FlakyTest
void logs() throws Exception {
List<LogEntry> logs = new CopyOnWriteArrayList<>();
Flux<LogEntry> receive = TestsUtils.receive(logQueue, l -> logs.add(l.getLeft()));