fix(tests): don't lock db when doing queue.receive

kestra-io · Jun 12, 2024 · 8daccdc · 8daccdc
1 parent dfa5151
commit 8daccdc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/plugin-debezium-oracle/src/test/java/io/kestra/plugin/debezium/oracle/TriggerTest.java b/plugin-debezium-oracle/src/test/java/io/kestra/plugin/debezium/oracle/TriggerTest.java
@@ -89,12 +89,12 @@ void flow() throws Exception {
             AtomicReference<Execution> last = new AtomicReference<>();
 
             // wait for execution
-            executionQueue.receive(execution -> {
+            executionQueue.receive(null, execution -> {
                 last.set(execution.getLeft());
 
                 queueCount.countDown();
                 assertThat(execution.getLeft().getFlowId(), is("trigger"));
-            });
+            }, false);
 
             worker.run();
             scheduler.run();