From 4099e447aed6fa53ba5bbb5d1a0c0c4058a257e4 Mon Sep 17 00:00:00 2001
From: Jonas Arnhold <jonasarnhold@web.de>
Date: Wed, 29 May 2024 19:06:47 +0200
Subject: [PATCH] Fix FAILED executions

---
 .../bakdata/conquery/sql/conquery/SqlExecutionManager.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conquery/SqlExecutionManager.java b/backend/src/main/java/com/bakdata/conquery/sql/conquery/SqlExecutionManager.java
index 5fb2e663ad..aa785bb5f3 100644
--- a/backend/src/main/java/com/bakdata/conquery/sql/conquery/SqlExecutionManager.java
+++ b/backend/src/main/java/com/bakdata/conquery/sql/conquery/SqlExecutionManager.java
@@ -78,6 +78,11 @@ private CompletableFuture<Void> executeAsync(ManagedQuery managedQuery) {
 									managedQuery.setLastResultCount(((long) result.getRowCount()));
 									managedQuery.finish(ExecutionState.DONE);
 									runningExecutions.remove(managedQuery.getId());
+								})
+								.exceptionally(e -> {
+									managedQuery.finish(ExecutionState.FAILED);
+									runningExecutions.remove(managedQuery.getId());
+									return null;
 								});
 	}