Let recurse get passed through from the pssh client.

Author: Caid11

pssh/pssh_client.py

@@ -843,7 +843,7 @@ def copy_file(self, local_file, remote_file, recurse=False):
                                 {'recurse' : recurse})
                 for host in self.hosts]
 
-    def _copy_file(self, host, local_file, remote_file, recurse=False):
+    def _copy_file(self, host, local_file, remote_file, recurse):
         """Make sftp client, copy file"""
         if not host in self.host_clients or not self.host_clients[host]:
             _user, _port, _password, _pkey = self._get_host_config_values(host)
@@ -856,16 +856,17 @@ def _copy_file(self, host, local_file, remote_file, recurse=False):
                 proxy_port=self.proxy_port,
                 agent=self.agent,
                 channel_timeout=self.channel_timeout)
-        return self.host_clients[host].copy_file(local_file, remote_file,
+        return self.host_clients[host].copy_file(local_file, remote_file, recurse=recurse)
 
-    def copy_file_to_local(self, remote_file, local_file):
+    def copy_file_to_local(self, remote_file, local_file, recurse=False):
         """Copy remote file to local file in parallel
 
         :param remote_file: remote filepath to copy to local host
         :type remote_file: str
         :param local_file: local filepath on local host to copy file to
         :type local_file: str
-
+        :param recurse: whether or not to recurse
+        :type recurse: bool
         .. note ::
           Local directories in `local_file` that do not exist will be
           created as long as permissions allow.
@@ -877,14 +878,14 @@ def copy_file_to_local(self, remote_file, local_file):
         :rtype: List(:mod:`gevent.Greenlet`) of greenlets for remote copy \
         commands
         """
-        return [self.pool.spawn(self._copy_file_to_local, host, remote_file, local_file)
+        return [self.pool.spawn(self._copy_file_to_local, host, remote_file, local_file, recurse)
                 for host in self.hosts]
 
-    def _copy_file_to_local(self, host, remote_file, local_file):
+    def _copy_file_to_local(self, host, remote_file, local_file, recurse):
         """Make sftp client, copy file to local"""
         if not self.host_clients[host]:
             self.host_clients[host] = SSHClient(host, user=self.user,
                                                 password=self.password,
                                                 port=self.port, pkey=self.pkey,
                                                 forward_ssh_agent=self.forward_ssh_agent)
-        return self.host_clients[host].copy_file_to_local(remote_file, '_'.join([local_file, host]))
+        return self.host_clients[host].copy_file_to_local(remote_file, '_'.join([local_file, host]), recurse=recurse)