Update futures_mpi.py

quaquel · Mar 28, 2024 · 7c0eb9c · 7c0eb9c
1 parent b2be0b4
commit 7c0eb9c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/ema_workbench/em_framework/futures_mpi.py b/ema_workbench/em_framework/futures_mpi.py
@@ -126,7 +126,8 @@ def send_sentinel():
     for handler in get_rootlogger().handlers:
         if isinstance(handler, MPIHandler):
             _logger.debug("sending sentinel")
-            handler.emit(record)
+            # handler.emit(record)
+            handler.communicator.send(record, 0, 0)
 
 
 class MPIHandler(QueueHandler):