self = <test_service_retry_policies.TestServiceRetryPolicies testMethod=test_service_response_retry_policy>

    def test_service_response_retry_policy(self):
        mock_client = CosmosClient(self.host, self.masterKey)
        db = mock_client.get_database_client(self.TEST_DATABASE_ID)
        container = db.get_container_client(self.TEST_CONTAINER_ID)
    
        created_item = container.create_item({"id": str(uuid.uuid4()), "pk": str(uuid.uuid4())})
    
        # Change the location cache to have 3 preferred read regions
        original_location_cache = mock_client.client_connection._global_endpoint_manager.location_cache
        self._setup_read_regions(original_location_cache, [self.REGION1, self.REGION2, self.REGION3])
    
        mf = self.MockExecuteServiceResponseExceptionIgnoreQuery(Exception, _retry_utility.ExecuteFunction)
        with patch.object(_retry_utility, 'ExecuteFunction', mf):
            with pytest.raises(ServiceResponseError):
                container.read_item(created_item['id'], created_item['pk'])
>           assert mf.counter == 3
E           assert 1 == 3
E            +  where 1 = <test_service_retry_policies.TestServiceRetryPolicies.MockExecuteServiceResponseExceptionIgnoreQuery object at 0x000002666A3D7460>.counter

tests\test_service_retry_policies.py:120: AssertionError

self = <test_shared_cache_integration_async.TestSharedCacheIntegrationAsync testMethod=test_clear_cache_triggers_repopulation_async>

    async def test_clear_cache_triggers_repopulation_async(self):
        """Async: After clear_cache(), the next routing-map fetch transparently re-populates."""
        await self._populate_cache(self.client1, self.container)
        cache = self._get_cache_dict(self.client1)
        self.assertTrue(len(cache) > 0)
    
        provider = self._get_routing_provider(self.client1)
        provider.clear_cache()
>       self.assertEqual(len(cache), 0)
E       AssertionError: 1 != 0

tests\test_shared_cache_integration_async.py:118: AssertionError