diff --git a/src/driver/src/main/java/com/edgedb/driver/clients/EdgeDBBinaryClient.java b/src/driver/src/main/java/com/edgedb/driver/clients/EdgeDBBinaryClient.java index a5b68f3..870abe9 100644 --- a/src/driver/src/main/java/com/edgedb/driver/clients/EdgeDBBinaryClient.java +++ b/src/driver/src/main/java/com/edgedb/driver/clients/EdgeDBBinaryClient.java @@ -299,12 +299,7 @@ public final CompletionStage executeQuery( @NotNull ExecutionArguments args ) { logger.debug("Execute request: is connected? {}", getDuplexer().isConnected()); - if(!getDuplexer().isConnected()) { - // TODO: check for recursion - return reconnect() - .thenCompose(v -> executeQuery(args)); - } - + final var hasReleased = new AtomicBoolean(); return CompletableFuture.runAsync(() -> {