Fixed blocking problem

PalNilsson · Dec 10, 2024 · 45ca4e3 · 45ca4e3
1 parent 077148f
commit 45ca4e3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pilot/info/jobdata.py b/pilot/info/jobdata.py
@@ -1088,7 +1088,8 @@ def collect_zombies(self, depth: int = None):
             for zombie in self.zombies:
                 try:
                     logger.info(f"zombie collector waiting for pid {zombie}")
-                    _id, _ = os.waitpid(zombie, os.WNOHANG if current_depth else 0)
+                    # dangerous, can lead to blocking : _id, _ = os.waitpid(zombie, os.WNOHANG if current_depth else 0)
+                    _id, _ = os.waitpid(zombie, os.WNOHANG)
                 except OSError as exc:
                     logger.info(f"harmless exception when collecting zombies: {exc}")
                     zombies_to_remove.append(zombie)