diff --git a/instrumentation/vertx/vertx-sql-client-4.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/vertx/v4_0/sql/VertxSqlClientTest.java b/instrumentation/vertx/vertx-sql-client-4.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/vertx/v4_0/sql/VertxSqlClientTest.java index ca5891b4e2..589533a9bc 100644 --- a/instrumentation/vertx/vertx-sql-client-4.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/vertx/v4_0/sql/VertxSqlClientTest.java +++ b/instrumentation/vertx/vertx-sql-client-4.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/vertx/v4_0/sql/VertxSqlClientTest.java @@ -373,23 +373,22 @@ class VertxSqlClientTest { for (CompletableFuture future : futureList) { executorService.submit( () -> { - testing - .runWithSpan( - "parent", - () -> - pool.withConnection( + testing.runWithSpan( + "parent", + () -> + pool.withConnection( conn -> conn.preparedQuery("select * from test where id = $1") - .execute(Tuple.of(1)))) - .onComplete( - rowSetAsyncResult -> { - if (rowSetAsyncResult.succeeded()) { - future.complete(rowSetAsyncResult.result()); - } else { - future.completeExceptionally(rowSetAsyncResult.cause()); - } - latch.countDown(); - }); + .execute(Tuple.of(1))) + .onComplete( + rowSetAsyncResult -> { + if (rowSetAsyncResult.succeeded()) { + future.complete(rowSetAsyncResult.result()); + } else { + future.completeExceptionally(rowSetAsyncResult.cause()); + } + latch.countDown(); + })); }); } latch.await(30, TimeUnit.SECONDS);