(self, parsed_args, parsed_globals)
| 301 | ] |
| 302 | |
| 303 | def _run_main_command(self, parsed_args, parsed_globals): |
| 304 | master_dns = sshutils.validate_and_find_master_dns( |
| 305 | session=self._session, |
| 306 | parsed_globals=parsed_globals, |
| 307 | cluster_id=parsed_args.cluster_id, |
| 308 | ) |
| 309 | |
| 310 | key_file = parsed_args.key_pair_file |
| 311 | sshutils.validate_scp_with_key_file(key_file) |
| 312 | if emrutils.which('scp') or emrutils.which('scp.exe'): |
| 313 | ssh_options = _build_ssh_options(parsed_args.ssh_options) |
| 314 | command = ['scp', '-r'] + ssh_options + [ |
| 315 | '-i', parsed_args.key_pair_file, |
| 316 | constants.SSH_USER + '@' + master_dns + ':' + parsed_args.src, |
| 317 | ] |
| 318 | else: |
| 319 | if parsed_args.ssh_options: |
| 320 | sys.stderr.write(PUTTY_SSH_OPTIONS_MSG) |
| 321 | command = [ |
| 322 | 'pscp', '-scp', '-r', '-i', parsed_args.key_pair_file, |
| 323 | constants.SSH_USER + '@' + master_dns + ':' + parsed_args.src, |
| 324 | ] |
| 325 | |
| 326 | if parsed_args.dest: |
| 327 | command.append(parsed_args.dest) |
| 328 | else: |
| 329 | command.append(parsed_args.src.split('/')[-1]) |
| 330 | print(' '.join(command)) |
| 331 | rc = subprocess.call(command) |
| 332 | return rc |
nothing calls this directly
no test coverage detected