diff --git a/src/test/java/io/kestra/plugin/fs/AbstractTriggerTest.java b/src/test/java/io/kestra/plugin/fs/AbstractTriggerTest.java
index c96f846..e56aee3 100644
--- 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"));
             });