diff --git a/src/test/java/io/kestra/plugin/gcp/bigquery/TriggerTest.java b/src/test/java/io/kestra/plugin/gcp/bigquery/TriggerTest.java
index 602174e7..464dd034 100644
--- a/src/test/java/io/kestra/plugin/gcp/bigquery/TriggerTest.java
+++ b/src/test/java/io/kestra/plugin/gcp/bigquery/TriggerTest.java
@@ -76,10 +76,10 @@ void flow() throws Exception {
 
             // wait for execution
             executionQueue.receive(TriggerTest.class, execution -> {
-                last.set(execution);
+                last.set(execution.getLeft());
 
                 queueCount.countDown();
-                assertThat(execution.getFlowId(), is("bigquery-listen"));
+                assertThat(execution.getLeft().getFlowId(), is("bigquery-listen"));
             });
 
 
diff --git a/src/test/java/io/kestra/plugin/gcp/gcs/TriggerTest.java b/src/test/java/io/kestra/plugin/gcp/gcs/TriggerTest.java
index 07c21b5e..00a93709 100644
--- a/src/test/java/io/kestra/plugin/gcp/gcs/TriggerTest.java
+++ b/src/test/java/io/kestra/plugin/gcp/gcs/TriggerTest.java
@@ -82,10 +82,10 @@ void flow() throws Exception {
 
             // wait for execution
             executionQueue.receive(TriggerTest.class, execution -> {
-                last.set(execution);
+                last.set(execution.getLeft());
 
                 queueCount.countDown();
-                assertThat(execution.getFlowId(), is("gcs-listen"));
+                assertThat(execution.getLeft().getFlowId(), is("gcs-listen"));
             });
 
 
diff --git a/src/test/java/io/kestra/plugin/gcp/pubsub/TriggerTest.java b/src/test/java/io/kestra/plugin/gcp/pubsub/TriggerTest.java
index 07362b1e..141bdd91 100644
--- a/src/test/java/io/kestra/plugin/gcp/pubsub/TriggerTest.java
+++ b/src/test/java/io/kestra/plugin/gcp/pubsub/TriggerTest.java
@@ -74,10 +74,10 @@ void flow() throws Exception {
 
             // wait for execution
             executionQueue.receive(TriggerTest.class, execution -> {
-                last.set(execution);
+                last.set(execution.getLeft());
 
                 queueCount.countDown();
-                assertThat(execution.getFlowId(), is("pubsub-listen"));
+                assertThat(execution.getLeft().getFlowId(), is("pubsub-listen"));
             });