How to block in onComplete function?

[diversit]

I have a job (in Quarkus) with an async flow which does some processing on a fixed number of items.
In the onComplete function it has to persist the job result. This is an async db action (using reactive-pg-client). After this, the job exists.
How do I wait for the db action to be completed?

Using

steps.persistProcessResult(results)
        .await().indefinitely();

throws a ERROR [io.qua.ver.cor.run.VertxCoreRecorder] (vert.x-eventloop-thread-4) Uncaught exception received by Vert.x: java.lang.IllegalStateException: The current thread cannot be blocked: vert.x-eventloop-thread-4

I have tried to use runOnSubscriptionOn and emitOn with Infrastructure.defaultWorkerPool, Infrastructure.getDefaultExecutor and several thread pools from the Executors class, but all keep giving the same failure.

I have also tried to add @Blocking on the persistProcessResults function. Also did not work.

[jponge]

Calling .await().indefinitely() is blocking, and it will block the event-loop.

What onComplete method are you talking about?

If that's a Vert.x Future then you should use the Mutiny Vert.x bindings of the Vert.x Postgres client, then use Uni methods to compose async code processing. See https://github.com/smallrye/smallrye-mutiny-vertx-bindings/tree/main/vertx-mutiny-clients/vertx-mutiny-pg-client