refactor(test): adjust to last oss queue signature

relate to kestra-io/kestra#1981
gorgias · Sep 5, 2023 · 3d7e50e · 3d7e50e
1 parent 13d96e3
commit 3d7e50e
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git 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
@@ -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
@@ -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"));
             });