diff --git a/lib/ansible/executor/task_executor.py b/lib/ansible/executor/task_executor.py
index 1c6346d94a..8c8990a97d 100644
--- a/lib/ansible/executor/task_executor.py
+++ b/lib/ansible/executor/task_executor.py
@@ -128,13 +128,6 @@ class TaskExecutor:
             return result
         except AnsibleError as e:
             return dict(failed=True, msg=to_unicode(e, nonstring='simplerepr'))
-        finally:
-            try:
-                self._connection.close()
-            except AttributeError:
-                pass
-            except Exception as e:
-                debug("error closing connection: %s" % to_unicode(e))
 
     def _get_loop_items(self):
         '''