diff options
| -rwxr-xr-x | lib/ansible/runner.py | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/lib/ansible/runner.py b/lib/ansible/runner.py index 0218ea2406..4e4fd25573 100755 --- a/lib/ansible/runner.py +++ b/lib/ansible/runner.py @@ -75,7 +75,7 @@ class Runner(object): remote_port=C.DEFAULT_REMOTE_PORT, background=0, basedir=None, setup_cache=None, transport='paramiko', conditional='True', groups={}, callbacks=None, verbose=False, debug=False, sudo=False, extra_vars=None): - + if setup_cache is None: setup_cache = {} if basedir is None: @@ -637,13 +637,13 @@ class Runner(object): prc.start() workers.append(prc) - try: - for worker in workers: - worker.join() - except KeyboardInterrupt: - for worker in workers: - worker.terminate() - worker.join() + try: + for worker in workers: + worker.join() + except KeyboardInterrupt: + for worker in workers: + worker.terminate() + worker.join() results = [] while not result_queue.empty(): |