refactor(test): adjust to last oss queue signature

relate to kestra-io/kestra#1981
kestra-io · Sep 5, 2023 · 37df21a · 37df21a
1 parent 98c571c
commit 37df21a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/test/java/io/kestra/plugin/amqp/TriggerTest.java b/src/test/java/io/kestra/plugin/amqp/TriggerTest.java
@@ -69,10 +69,10 @@ void flow() throws Exception {
             AtomicReference<Execution> last = new AtomicReference<>();
 
             executionQueue.receive(TriggerTest.class, execution -> {
-                last.set(execution);
+                last.set(execution.getLeft());
 
                 queueCount.countDown();
-                assertThat(execution.getFlowId(), is("trigger"));
+                assertThat(execution.getLeft().getFlowId(), is("trigger"));
             });
             Publish task = Publish.builder()
                 .id(TriggerTest.class.getSimpleName())