refactor(test): adjust to last oss queue signature

relate to kestra-io/kestra#1981
kestra-io · Sep 5, 2023 · 89debe5 · 89debe5
1 parent 231f037
commit 89debe5
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/test/java/io/kestra/plugin/azure/batch/job/CreateTest.java b/src/test/java/io/kestra/plugin/azure/batch/job/CreateTest.java
@@ -87,7 +87,7 @@ private Create.Output create(List<Task> tasks, Map<String, Object> inputs) throw
     @Test
     void run() throws Exception {
         ArrayList<LogEntry> objects = new ArrayList<>();
-        logQueue.receive(objects::add);
+        logQueue.receive(l -> objects.add(l.getLeft()));
 
         String random = IdUtils.create();
         SharedAccess.Output outputs = sas(this.container, null, SharedAccess.Permission.WRITE);
@@ -179,7 +179,7 @@ void run() throws Exception {
     @Test
     void errors() throws Exception {
         ArrayList<LogEntry> objects = new ArrayList<>();
-        logQueue.receive(objects::add);
+        logQueue.receive(l -> objects.add(l.getLeft()));
 
         Exception exception = assertThrows(Exception.class, () -> {
             create(

diff --git a/src/test/java/io/kestra/plugin/azure/storage/blob/TriggerTest.java b/src/test/java/io/kestra/plugin/azure/storage/blob/TriggerTest.java
@@ -58,10 +58,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("blob-storage-listen"));
+                assertThat(execution.getLeft().getFlowId(), is("blob-storage-listen"));
             });