Merge branch 'louder' into test-letstest-all-changes2

This commit is contained in:
Brad Warren 2019-05-16 10:31:28 -07:00
commit c6537a3d6f

View file

@ -553,8 +553,12 @@ def main():
for i in range(num_processes):
inqueue.put(SENTINEL)
# wait on termination of client processes
timeout = 5 * 60
for p in jobs:
p.join()
p.join(timeout)
while p.is_alive():
print('Waiting on client processes...')
p.join(timeout)
# add SENTINEL to output queue
outqueue.put(SENTINEL)