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