refactor(test): adjust to last oss queue signature

relate to kestra-io/kestra#1981
kestra-io · Sep 5, 2023 · e22e6f8 · e22e6f8
1 parent 8054d12
commit e22e6f8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/plugin-jdbc/src/test/java/io/kestra/plugin/jdbc/AbstractJdbcTriggerTest.java b/plugin-jdbc/src/test/java/io/kestra/plugin/jdbc/AbstractJdbcTriggerTest.java
@@ -66,10 +66,10 @@ protected Execution triggerFlow(ClassLoader classLoader, String flowRepository,
 
             // wait for execution
             executionQueue.receive(execution -> {
-                last.set(execution);
+                last.set(execution.getLeft());
 
                 queueCount.countDown();
-                assertThat(execution.getFlowId(), is(flow));
+                assertThat(execution.getLeft().getFlowId(), is(flow));
             });
 
             worker.run();