From 5f88f503db6eaf3ea7b909854b4676fb251f79e6 Mon Sep 17 00:00:00 2001
From: Jan Janssen <janssen@mpie.de>
Date: Tue, 7 Nov 2023 09:06:07 +0100
Subject: [PATCH] Join Queues

---
 pympipool/shared/executorbase.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/pympipool/shared/executorbase.py b/pympipool/shared/executorbase.py
index 232367fa..9e75f31a 100644
--- a/pympipool/shared/executorbase.py
+++ b/pympipool/shared/executorbase.py
@@ -135,6 +135,7 @@ def execute_parallel_tasks_loop(interface, future_queue):
         if "shutdown" in task_dict.keys() and task_dict["shutdown"]:
             interface.shutdown(wait=task_dict["wait"])
             future_queue.task_done()
+            future_queue.join()
             break
         elif "fn" in task_dict.keys() and "future" in task_dict.keys():
             f = task_dict.pop("future")
@@ -175,6 +176,7 @@ def executor_broker(
                 future_queue.task_done()
             else:
                 future_queue.task_done()
+                future_queue.join()
                 break