@@ -130,11 +130,25 @@ def test_get_service_account_token_missing_token_uri_key(self):
130130 get_service_account_token (CREDENTIALS_WITHOUT_TOKEN_URI , {}, None )
131131 self .assertEqual (context .exception .message , SkyflowMessages .Error .MISSING_TOKEN_URI .value )
132132
133- def test_get_service_account_token_with_valid_credentials (self ):
133+ @patch ("skyflow.service_account._utils.AuthClient" )
134+ @patch ("skyflow.service_account._utils.get_signed_jwt" )
135+ def test_get_service_account_token_with_valid_credentials (self , mock_get_signed_jwt , mock_auth_client ):
136+ mock_get_signed_jwt .return_value = "signed"
137+ mock_auth_api = mock_auth_client .return_value .get_auth_api .return_value
138+ mock_auth_api .authentication_service_get_auth_token .return_value = type (
139+ "obj" , (), {"access_token" : "mock_token" , "token_type" : "bearer" }
140+ )
134141 access_token , _ = get_service_account_token (VALID_SERVICE_ACCOUNT_CREDS , {}, None )
135142 self .assertTrue (access_token )
136143
137- def test_get_service_account_token_with_snake_case_creds (self ):
144+ @patch ("skyflow.service_account._utils.AuthClient" )
145+ @patch ("skyflow.service_account._utils.get_signed_jwt" )
146+ def test_get_service_account_token_with_snake_case_creds (self , mock_get_signed_jwt , mock_auth_client ):
147+ mock_get_signed_jwt .return_value = "signed"
148+ mock_auth_api = mock_auth_client .return_value .get_auth_api .return_value
149+ mock_auth_api .authentication_service_get_auth_token .return_value = type (
150+ "obj" , (), {"access_token" : "mock_token" , "token_type" : "bearer" }
151+ )
138152 access_token , _ = get_service_account_token (SNAKE_CASE_CREDS , {}, None )
139153 self .assertTrue (access_token )
140154
0 commit comments