From fb51feda91aecd98270a513de4645707d1c4c3c1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lo=C3=AFc=20Mathieu?= Date: Thu, 7 Sep 2023 10:02:39 +0200 Subject: [PATCH] fix(core): bad merge on TemplateTest --- core/src/test/java/io/kestra/core/Helpers.java | 2 +- .../test/java/io/kestra/core/tasks/flows/TemplateTest.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/core/src/test/java/io/kestra/core/Helpers.java b/core/src/test/java/io/kestra/core/Helpers.java index 35288dbad49..9a8beadc6ac 100644 --- a/core/src/test/java/io/kestra/core/Helpers.java +++ b/core/src/test/java/io/kestra/core/Helpers.java @@ -19,7 +19,7 @@ import java.util.function.Consumer; public class Helpers { - public static long FLOWS_COUNT = 66; + public static long FLOWS_COUNT = 67; public static ApplicationContext applicationContext() throws URISyntaxException { return applicationContext( diff --git a/core/src/test/java/io/kestra/core/tasks/flows/TemplateTest.java b/core/src/test/java/io/kestra/core/tasks/flows/TemplateTest.java index 593b50612a0..94ee618d913 100644 --- a/core/src/test/java/io/kestra/core/tasks/flows/TemplateTest.java +++ b/core/src/test/java/io/kestra/core/tasks/flows/TemplateTest.java @@ -12,6 +12,7 @@ import io.kestra.core.runners.ListenersTest; import io.kestra.core.runners.RunnerUtils; import io.kestra.core.tasks.log.Log; +import io.kestra.core.utils.TestsUtils; import jakarta.inject.Inject; import jakarta.inject.Named; import org.junit.jupiter.api.Test; @@ -84,8 +85,7 @@ public static void withFailedTemplate(RunnerUtils runnerUtils, TemplateRepositor assertThat(execution.getTaskRunList(), hasSize(1)); assertThat(execution.getState().getCurrent(), is(State.Type.FAILED)); - LogEntry matchingLog = TestsUtils.awaitLog(logs, logEntry -> logEntry.getMessage().endsWith("Can't find flow template 'io.kestra.tests.invalid'") && logEntry.getLevel() == Level.ERROR); - assertThat(matchingLog, notNullValue()); + assertThat(logs.stream().filter(logEntry -> logEntry.getMessage().endsWith("Can't find flow template 'io.kestra.tests.invalid'")).findFirst().orElseThrow().getLevel(), is(Level.ERROR)); } @Test