refactor(test): adjust to last oss queue signature

relate to kestra-io/kestra#1981
kestra-io · Sep 5, 2023 · debd033 · debd033
1 parent 98168dc
commit debd033
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/test/java/io/kestra/plugin/fs/AbstractTriggerTest.java b/src/test/java/io/kestra/plugin/fs/AbstractTriggerTest.java
@@ -76,10 +76,10 @@ void flow() throws Exception {
 
             // wait for execution
             executionQueue.receive(AbstractTriggerTest.class, execution -> {
-                last.set(execution);
+                last.set(execution.getLeft());
 
                 queueCount.countDown();
-                assertThat(execution.getFlowId(), containsString("ftp-listen"));
+                assertThat(execution.getLeft().getFlowId(), containsString("ftp-listen"));
             });