Don't call close() on ParallelSSHClient in case, for some reason it
hasn't been instantiated.
@@ -148,6 +148,7 @@ class BaseParallelSSHRunner(ActionRunner, ShellRunnerMixin):
super(BaseParallelSSHRunner, self).post_run(status=status, result=result)
# Ensure we close the connection when the action execution finishes
+ if self._parallel_ssh_client:
self._parallel_ssh_client.close()
def _is_private_key_material(self, private_key):
