We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d37fc25 commit 65b7727Copy full SHA for 65b7727
deepspeed/launcher/runner.py
@@ -443,7 +443,11 @@ def main(args=None):
443
if not args.master_addr:
444
assert multi_node_exec
445
first_host = list(active_resources.keys())[0]
446
- hostname_cmd = [f"ssh {first_host} hostname -I"]
+ ssh_check_cmd = "ssh "
447
+ if args.ssh_port is not None:
448
+ ssh_check_cmd += f" -p {args.ssh_port}"
449
+ ssh_check_cmd += f" {first_host} hostname -I"
450
+ hostname_cmd = [ssh_check_cmd]
451
try:
452
result = subprocess.check_output(hostname_cmd, shell=True)
453
except subprocess.CalledProcessError as err:
0 commit comments