a ƹDf@s2dZdgZddlmZGdddeZedkr.dS)a" This module contains the derived class for secure shell (ssh) launchers See the following for an example. Usage ===== A typical call to a 'ssh pipe' will roughly follow this example: >>> # instantiate the pipe, providing it with a unique identifier >>> pipe = Pipe('launcher') >>> >>> # configure the pipe to perform the command on the selected host >>> pipe(command='hostname', host='remote.host.edu') >>> >>> # execute the launch and retrieve the response >>> pipe.launch() >>> print(pipe.response()) Pipe)rcs.eZdZdZdfdd ZddZeZZS)rz>a popen-based ssh-pipe for parallel and distributed computing.Nc sF|dd|_|dd|_|dd|_tt|j|fi|dS)acreate a ssh pipe Inputs: name: a unique identifier (string) for the pipe host: hostname to recieve command [user@host is also valid] command: a command to send [default = 'echo '] launcher: remote service mechanism (i.e. ssh, rsh) [default = 'ssh'] options: remote service options (i.e. -v, -N, -L) [default = ''] background: run in background [default = False] decode: ensure response is 'ascii' [default = True] stdin: file-like object to serve as standard input for the remote process launchersshoptionshost localhostN)poprrrsuperr__init__)selfnamekwds __class__e/nfs/NAS7/SABIOD/METHODE/ermites/ermites_venv/lib/python3.9/site-packages/pathos/secure/connection.pyr 's z Pipe.__init__c szjdurdj_njr4jjdd_jrPjjdd_jrpjjdd_d}j|sj|rjdd_j durddl }|j _ | D]|\}}|dkr|_q|dkr|_q|d kr|_q|d kr|_q|d kr|_ q|d kr,|_ q|d kr|_ qd_djjjjf_gd}tfdd|DS)a3configure a remote command using given keywords: (Re)configure the copier for the following inputs: host: hostname to recieve command [user@host is also valid] command: a command to send [default = 'echo '] launcher: remote service mechanism (i.e. ssh, rsh) [default = 'ssh'] options: remote service options (i.e. -v, -N, -L) [default = ''] background: run in background [default = False] decode: ensure response is 'ascii' [default = True] stdin: file-like object to serve as standard input for the remote process Nzecho %s)"'rcommandrrr backgrounddecodestdinz %s %s %s "%s")messagerrrrrcodecc3s|]}|t|fVqdS)N)getattr).0ir rr kzPipe.config..)rr rsplitrrstrip startswithendswithrsysitemsrrZ_stdoutdict)r rquoter'keyvaluenamesrr rconfig:sJ     z Pipe.config)N)__name__ __module__ __qualname____doc__r r.__call__ __classcell__rrrrr$s 4__main__N)r2__all__Zpathos.connectionrZ_Piper/rrrr s  N