@@ -1339,17 +1339,17 @@ def get_node_ips(cluster_yaml: str,
1339
1339
break
1340
1340
if len (worker_ips ) != expected_num_nodes - 1 :
1341
1341
n = expected_num_nodes - 1
1342
- # This could be triggered if e.g., some logging is added in
1343
- # skypilot_config, a module that has some code executed whenever
1344
- # `sky` is imported.
1345
- logger .warning (
1346
- f'Expected { n } worker IP(s); found '
1347
- f'{ len (worker_ips )} : { worker_ips } '
1348
- '\n This could happen if there is extra output from '
1349
- '`ray get-worker-ips`, which should be inspected below.'
1350
- f'\n == Output ==\n { out } '
1351
- f'\n == Output ends ==' )
1352
1342
if len (worker_ips ) > n :
1343
+ # This could be triggered if e.g., some logging is added in
1344
+ # skypilot_config, a module that has some code executed whenever
1345
+ # `sky` is imported.
1346
+ logger .warning (
1347
+ f'Expected { n } worker IP(s); found '
1348
+ f'{ len (worker_ips )} : { worker_ips } '
1349
+ '\n This could happen if there is extra output from '
1350
+ '`ray get-worker-ips`, which should be inspected below.'
1351
+ f'\n == Output ==\n { out } '
1352
+ f'\n == Output ends ==' )
1353
1353
logger .warning (f'\n Proceeding with the last { n } '
1354
1354
f'detected IP(s): { worker_ips [- n :]} .' )
1355
1355
worker_ips = worker_ips [- n :]
0 commit comments