diff --git a/moulinette/utils/process.py b/moulinette/utils/process.py index e3a760d9..b8d5b915 100644 --- a/moulinette/utils/process.py +++ b/moulinette/utils/process.py @@ -77,7 +77,7 @@ def call_async_output(args, callback, **kwargs): while True: try: - callback, message = log_queue.get_nowait() + callback, message = log_queue.get(True, 1) except queue.Empty: break