absurdfarce commented on PR #1918: URL: https://github.com/apache/cassandra-java-driver/pull/1918#issuecomment-1994643967
I think we're talking about different whenComplete() blocks. The newInstance() call throws an exception inside the whenComplete block that starts with this code: ```java initControlConnectionForSchema() .thenCompose(v -> context.getTopologyMonitor().checkSchemaAgreement()) .whenComplete( (schemaInAgreement, agreementError) -> { ... ``` The thenApplyAsync() and subsequent whenComplete() calls never actually happen because the exception thrown by schemaQueriesFactory.newInstance() exits the BiConsumer passed to the enclosing whenComplete() (shown in the code above). This code then exits with a stage that returned exceptionally (using the exception thrown by schemaQueriesFactory.newInstance()) per the Javadoc above. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org