From 3d7e50e98be7c3581e837d74b60b25f8b918f9aa Mon Sep 17 00:00:00 2001 From: Ludovic DEHON Date: Tue, 5 Sep 2023 15:52:08 +0200 Subject: [PATCH] refactor(test): adjust to last oss queue signature relate to kestra-io/kestra#1981 --- src/test/java/io/kestra/plugin/gcp/bigquery/TriggerTest.java | 4 ++-- src/test/java/io/kestra/plugin/gcp/gcs/TriggerTest.java | 4 ++-- src/test/java/io/kestra/plugin/gcp/pubsub/TriggerTest.java | 4 ++-- 3 files changed, 6 insertions(+), 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 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")); });