Add exit debug loggin

materialsproject · Sep 26, 2022 · b5bcc0e · b5bcc0e
1 parent ccc1876
commit b5bcc0e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/maggma/cli/distributed.py b/src/maggma/cli/distributed.py
@@ -121,6 +121,9 @@ def manager(
 
                             # If everything is distributed, send EXIT to the worker
                             if all(chunk["distributed"] for chunk in chunk_dicts):
+                                logger.debug(
+                                    f"Sending exit signal to worker: {msg.split('_')[1]}"
+                                )
                                 socket.send_multipart([identity, b"", b"EXIT"])
 
                 elif "ERROR" in msg: