def __init__(self, max_async_threads=2):
        """
        :type args: int
        :param args: maximun number of async command executors
        """

        self.jump_host_ssh = None
        self.ssh = paramiko.SSHClient()
        self.ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
        self.executor = ThreadPoolExecutor(max_workers=max_async_threads)
        self.futures = []
def __init__ ( self , max_async_threads = 2 ) : self . jump_host_ssh = None self . ssh = paramiko . SSHClient ( ) self . ssh . set_missing_host_key_policy ( paramiko . AutoAddPolicy ( ) ) self . executor = ThreadPoolExecutor ( max_workers = max_async_threads ) self . futures = [ ]
:type args: int
        :param args: maximun number of async command executors