diff --git a/lib/ansible/runner.py b/lib/ansible/runner.py
index 0218ea2406e..4e4fd255731 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():