cleanup dead children every seconds

Author: davies

python/pyspark/daemon.py

@@ -119,13 +119,16 @@ def handle_sigterm(*args):
     try:
         while True:
             try:
-                ready_fds = select.select([0, listen_sock], [], [])[0]
+                ready_fds = select.select([0, listen_sock], [], [], 1)[0]
             except select.error as ex:
                 if ex[0] == EINTR:
                     continue
                 else:
                     raise
 
+            # cleanup in signal handler will cause deadlock
+            cleanup_dead_children()
+
             if 0 in ready_fds:
                 try:
                     worker_pid = read_int(sys.stdin)
@@ -145,8 +148,6 @@ def handle_sigterm(*args):
                         continue
                     raise
 
-                # cleanup in signal handler will cause deadlock
-                cleanup_dead_children()
 
                 # Launch a worker process
                 try: