void () { PyDebugValueExecutionService.getInstance(myProject).sessionStopped(this); notifySessionStopped(); myCallbackHashMap.clear(); new Task.Backgroundable(myProject, PyBundle.message("console.close.console.communication"), false) { @Override public void run(@NotNull ProgressIndicator indicator) { try { closeCommunication().get(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } catch (ExecutionException e) { // it could help us diagnose some intricate cases LOG.debug(e); } } }.queue(); }