File tree Expand file tree Collapse file tree 1 file changed +11
-1
lines changed
python/ray/autoscaler/_private/_azure Expand file tree Collapse file tree 1 file changed +11
-1
lines changed Original file line number Diff line number Diff line change 7
7
from typing import List , Optional
8
8
from uuid import uuid4
9
9
10
+ from azure .common .credentials import get_cli_profile
10
11
from azure .core .exceptions import ResourceNotFoundError
11
12
from azure .identity import DefaultAzureCredential
12
13
from azure .mgmt .compute import ComputeManagementClient
@@ -66,7 +67,16 @@ class AzureNodeProvider(NodeProvider):
66
67
67
68
def __init__ (self , provider_config , cluster_name ):
68
69
NodeProvider .__init__ (self , provider_config , cluster_name )
69
- subscription_id = provider_config ["subscription_id" ]
70
+ subscription_id = provider_config .get ("subscription_id" )
71
+ if subscription_id is None :
72
+ # Get subscription from logged in azure profile
73
+ # if it isn't provided in the provider_config
74
+ # so operations like `get-head-ip` will work
75
+ subscription_id = get_cli_profile ().get_subscription_id ()
76
+ logger .info (
77
+ "subscription_id not found in provider config, falling back "
78
+ f"to subscription_id from the logged in azure profile: { subscription_id } "
79
+ )
70
80
self .cache_stopped_nodes = provider_config .get ("cache_stopped_nodes" , True )
71
81
credential = DefaultAzureCredential (exclude_shared_token_cache_credential = True )
72
82
self .compute_client = ComputeManagementClient (credential , subscription_id )
You can’t perform that action at this time.
0 commit comments