sockets to block until when the process ends didn't work.
This patch inserts a simple sleep(1) (second) into the code that
waits for the jobs to finish to prevent the queue manager from rapidly
spinning.
It should probably be fixed with a better way of monitoring for when
a process finishes
import subprocess
import select
import sys
+import time
class QueueCommands(object):
"""
queue_log.info("Process %d finished [%d]",
pending.pid, pending.returncode)
del self.running[pending_fd]
-
+ time.sleep(1)