@@ -333,37 +333,38 @@ async def test_log_analytics_query_async(self):
333333 def test_cloud_info (self ):
334334 if ".dev." in self .engine_cs :
335335 pytest .skip ("This test is not relevant for dev clusters" )
336-
336+
337337 # Clear the cache before testing
338338 with CloudSettings ._cloud_cache_lock :
339339 CloudSettings ._cloud_cache .clear ()
340-
340+
341341 # Get cloud info for the original URI
342342 cloud_info = CloudSettings .get_cloud_info_for_cluster (self .engine_cs )
343343 assert cloud_info is not CloudSettings .DEFAULT_CLOUD
344344 assert cloud_info == CloudSettings .DEFAULT_CLOUD
345-
345+
346346 # Test same instance is returned for same authority
347347 assert cloud_info is CloudSettings .get_cloud_info_for_cluster (self .engine_cs )
348-
348+
349349 # Test different paths with same authority use the same cache entry
350350 with_path = urljoin (self .engine_cs , "/test1/test2/test3" )
351351 assert cloud_info is CloudSettings .get_cloud_info_for_cluster (with_path )
352-
352+
353353 # Test another path variation
354354 with_db_path = urljoin (self .engine_cs , "/database" )
355355 assert cloud_info is CloudSettings .get_cloud_info_for_cluster (with_db_path )
356-
356+
357357 # Test that URLs with different ports are cached separately
358358 from urllib .parse import urlparse
359+
359360 url_parts = urlparse (self .engine_cs )
360-
361+
361362 # Only run this test if the original URL doesn't already specify a port
362363 if not url_parts .port :
363364 # Create a URL with a different port
364365 with_port = f"{ url_parts .scheme } ://{ url_parts .netloc } :8080"
365366 port_cloud_info = CloudSettings .get_cloud_info_for_cluster (with_port )
366-
367+
367368 # Should be a different instance from the original
368369 assert port_cloud_info is not cloud_info
369370
0 commit comments