} catch (ConditionFailedWithExceptionError error) {
                handleFailure(error.getCause());
            } catch (Throwable t) {
                handleFailure(t);
            }
        }

        private void handleFailure(Throwable t) {
            if (!annotation.type().isInstance(t)) {
                throw new WrongExceptionThrownError(annotation.type(), t);

                                }
                            }

                            @Override
                            public void handleFailure(Throwable failure) {
                                LOGGER.error("Error while receiving file changes", failure);
                                fileWatchingStatistics.errorWhileReceivingFileChanges(failure);

            }

            node.finishExecution(this::recordNodeCompleted);
            if (node.isFailed()) {
                LOGGER.debug("Node {} failed", node);
                handleFailure(node);
            } else {
                LOGGER.debug("Node {} finished executing", node);
                node.visitPostExecutionNodes(postNode -> {
                    postNode.setIndex(node.getIndex());