fix: QueueException on test

kestra-io · Sep 12, 2024 · 7855e13 · 7855e13
1 parent 53be019
commit 7855e13
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/test/java/io/kestra/plugin/dbt/cloud/SerializationTest.java b/src/test/java/io/kestra/plugin/dbt/cloud/SerializationTest.java
@@ -4,6 +4,7 @@
 import io.kestra.core.junit.annotations.KestraTest;
 import io.kestra.core.models.executions.Execution;
 import io.kestra.core.models.flows.State;
+import io.kestra.core.queues.QueueException;
 import io.kestra.core.repositories.LocalFlowRepositoryLoader;
 import io.kestra.core.runners.RunContext;
 import io.kestra.core.runners.RunContextFactory;
@@ -55,7 +56,7 @@ protected void init() throws IOException, URISyntaxException {
     }
 
     @Test
-    void flow() throws TimeoutException {
+    void flow() throws TimeoutException, QueueException {
         EmbeddedServer embeddedServer = applicationContext.getBean(EmbeddedServer.class);
         embeddedServer.start();