+ // we are not willing to wait forever here..
+ boolean acquired = exited.tryAcquire(60, TimeUnit.SECONDS);
+ if (!acquired) {
+ LOGGER.error("Could not safely dispose query thread {} - we were processing task {} and still have tasks to do {}", index, currentTask.graph != null ? String.valueOf(currentTask) : "SessionTask with null graph", tasks.size());
+ interrupt();
+ }