[Storage] Migrate packages from setup.py to pyproject.toml #46652
Build #20260504.1 had test failures
Details
- Failed: 9 (0.08%)
- Passed: 10,625 (99.31%)
- Other: 65 (0.61%)
- Total: 10,699
Annotations
Check failure on line 35 in Build log
azure-pipelines / python - cosmos - ci
Build log #L35
The process '/mnt/vss/_work/1/s/venv/bin/python' failed with exit code 1
Check failure on line 27 in Build log
azure-pipelines / python - cosmos - ci
Build log #L27
There are one or more test failures detected in result files. Detailed summary of published test results can be viewed in the Tests tab.
Check failure on line 7337 in Build log
azure-pipelines / python - cosmos - ci
Build log #L7337
PowerShell exited with code '1'.
Check failure on line 1 in test_service_request_retry_policy_async
azure-pipelines / python - cosmos - ci
test_service_request_retry_policy_async
assert 1 == 3
+ where 1 = <test_service_retry_policies_async.TestServiceRetryPoliciesAsync.MockExecuteServiceRequestExceptionIgnoreQuery object at 0x0000021E8FD53B60>.counter
Raw output
self = <test_service_retry_policies_async.TestServiceRetryPoliciesAsync testMethod=test_service_request_retry_policy_async>
async def test_service_request_retry_policy_async(self):
# ServiceRequestErrors will always retry, and will retry once per preferred region
async with CosmosClient(self.host, self.masterKey) as mock_client:
db = mock_client.get_database_client(self.TEST_DATABASE_ID)
container = db.get_container_client(self.TEST_CONTAINER_ID)
created_item = await container.create_item({"id": str(uuid.uuid4()), "pk": str(uuid.uuid4())})
# Save the original function
self.original_execute_function = _retry_utility_async.ExecuteFunctionAsync
# Change the location cache to have 3 preferred read regions and 3 available read endpoints by location
original_location_cache = mock_client.client_connection._global_endpoint_manager.location_cache
original_location_cache.account_read_locations = [self.REGION1, self.REGION2, self.REGION3]
original_location_cache.available_read_regional_endpoints_by_locations = {
self.REGION1: self.REGIONAL_ENDPOINT,
self.REGION2: self.REGIONAL_ENDPOINT,
self.REGION3: self.REGIONAL_ENDPOINT}
original_location_cache.read_regional_routing_contexts = [self.REGIONAL_ENDPOINT, self.REGIONAL_ENDPOINT,
self.REGIONAL_ENDPOINT]
expected_counter = len(original_location_cache.read_regional_routing_contexts)
try:
# Mock the function to return the ServiceRequestException we retry
mf = self.MockExecuteServiceRequestExceptionIgnoreQuery(self.original_execute_function)
_retry_utility_async.ExecuteFunctionAsync = mf
> await container.read_item(created_item['id'], created_item['pk'])
tests\test_service_retry_policies_async.py:74:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\core\tracing\decorator_async.py:77: in wrapper_use_tracer
return await func(*args, **kwargs)
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\cosmos\aio\_container.py:397: in read_item
return await self.client_connection.ReadItem(document_link=doc_link, options=request_options, **kwargs)
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\cosmos\aio\_cosmos_client_connection_async.py:1100: in ReadItem
return await self.Read(path, http_constants.ResourceType.Document, document_id, None, options, **kwargs)
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\cosmos\aio\_cosmos_client_connection_async.py:1296: in Read
result, last_response_headers = await self.__Get(path, request_params, headers, **kwargs)
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\cosmos\aio\_cosmos_client_connection_async.py:1320: in __Get
return await asynchronous_request.AsynchronousRequest(
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\cosmos\aio\_asynchronous_request.py:241: in AsynchronousRequest
return await _retry_utility_async.ExecuteAsync(
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\cosmos\aio\_retry_utility_async.py:288: in ExecuteAsync
_handle_service_request_retries(client, service_request_retry_policy, e, *args)
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\cosmos\_retry_utility.py:354: in _handle_service_request_retries
raise exception
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\cosmos\aio\_retry_utility_async.py:139: in ExecuteAsync
result = await ExecuteFunctionAsync(function, global_endpoint_manager, *args, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
Check failure on line 1 in test_service_response_retry_policy_async
azure-pipelines / python - cosmos - ci
test_service_response_retry_policy_async
assert 1 == 3
+ where 1 = <test_service_retry_policies_async.TestServiceRetryPoliciesAsync.MockExecuteServiceResponseExceptionIgnoreQuery object at 0x0000021E8FD538C0>.counter
Raw output
self = <test_service_retry_policies_async.TestServiceRetryPoliciesAsync testMethod=test_service_response_retry_policy_async>
async def test_service_response_retry_policy_async(self):
# For ServiceResponseErrors, we only do cross region retries on read requests or on ClientConnectionErrors
# We also only do retries within the ConnectionRetryPolicy for the cases above
async with CosmosClient(self.host, self.masterKey) as mock_client:
db = mock_client.get_database_client(self.TEST_DATABASE_ID)
container = db.get_container_client(self.TEST_CONTAINER_ID)
created_item = await container.create_item({"id": str(uuid.uuid4()), "pk": str(uuid.uuid4())})
# Save the original function
self.original_execute_function = _retry_utility_async.ExecuteFunctionAsync
# Change the location cache to have 3 preferred read regions and 3 available read endpoints by location
original_location_cache = mock_client.client_connection._global_endpoint_manager.location_cache
original_location_cache.account_read_locations = [self.REGION1, self.REGION2, self.REGION3]
original_location_cache.available_read_regional_endpoints_by_locations = {
self.REGION1: self.REGIONAL_ENDPOINT,
self.REGION2: self.REGIONAL_ENDPOINT,
self.REGION3: self.REGIONAL_ENDPOINT}
original_location_cache.read_regional_routing_contexts = [self.REGIONAL_ENDPOINT, self.REGIONAL_ENDPOINT,
self.REGIONAL_ENDPOINT]
try:
# Mock the function to return the ClientConnectionError we retry
mf = self.MockExecuteServiceResponseExceptionIgnoreQuery(AttributeError,
None, self.original_execute_function)
_retry_utility_async.ExecuteFunctionAsync = mf
> await container.read_item(created_item['id'], created_item['pk'])
tests\test_service_retry_policies_async.py:166:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\core\tracing\decorator_async.py:77: in wrapper_use_tracer
return await func(*args, **kwargs)
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\cosmos\aio\_container.py:397: in read_item
return await self.client_connection.ReadItem(document_link=doc_link, options=request_options, **kwargs)
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\cosmos\aio\_cosmos_client_connection_async.py:1100: in ReadItem
return await self.Read(path, http_constants.ResourceType.Document, document_id, None, options, **kwargs)
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\cosmos\aio\_cosmos_client_connection_async.py:1296: in Read
result, last_response_headers = await self.__Get(path, request_params, headers, **kwargs)
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\cosmos\aio\_cosmos_client_connection_async.py:1320: in __Get
return await asynchronous_request.AsynchronousRequest(
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\cosmos\aio\_asynchronous_request.py:241: in AsynchronousRequest
return await _retry_utility_async.ExecuteAsync(
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\cosmos\aio\_retry_utility_async.py:307: in ExecuteAsync
_handle_service_response_retries(request, client, service_response_retry_policy, e, *args)
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\cosmos\_retry_utility.py:365: in _handle_service_response_retries
raise exception
..\..\..\.venv\azure-cosmos\.venv_mindependency\Lib\site-packages\azure\cosmos\aio\_retry_utility_async.py:139: in ExecuteAsync
result = await ExecuteFuncti
Check failure on line 1 in test_service_request_retry_policy_async
azure-pipelines / python - cosmos - ci
test_service_request_retry_policy_async
assert 1 == 3
+ where 1 = <test_service_retry_policies_async.TestServiceRetryPoliciesAsync.MockExecuteServiceRequestExceptionIgnoreQuery object at 0x0000021F9C8C82F0>.counter
Raw output
self = <test_service_retry_policies_async.TestServiceRetryPoliciesAsync testMethod=test_service_request_retry_policy_async>
async def test_service_request_retry_policy_async(self):
# ServiceRequestErrors will always retry, and will retry once per preferred region
async with CosmosClient(self.host, self.masterKey) as mock_client:
db = mock_client.get_database_client(self.TEST_DATABASE_ID)
container = db.get_container_client(self.TEST_CONTAINER_ID)
created_item = await container.create_item({"id": str(uuid.uuid4()), "pk": str(uuid.uuid4())})
# Save the original function
self.original_execute_function = _retry_utility_async.ExecuteFunctionAsync
# Change the location cache to have 3 preferred read regions and 3 available read endpoints by location
original_location_cache = mock_client.client_connection._global_endpoint_manager.location_cache
original_location_cache.account_read_locations = [self.REGION1, self.REGION2, self.REGION3]
original_location_cache.available_read_regional_endpoints_by_locations = {
self.REGION1: self.REGIONAL_ENDPOINT,
self.REGION2: self.REGIONAL_ENDPOINT,
self.REGION3: self.REGIONAL_ENDPOINT}
original_location_cache.read_regional_routing_contexts = [self.REGIONAL_ENDPOINT, self.REGIONAL_ENDPOINT,
self.REGIONAL_ENDPOINT]
expected_counter = len(original_location_cache.read_regional_routing_contexts)
try:
# Mock the function to return the ServiceRequestException we retry
mf = self.MockExecuteServiceRequestExceptionIgnoreQuery(self.original_execute_function)
_retry_utility_async.ExecuteFunctionAsync = mf
> await container.read_item(created_item['id'], created_item['pk'])
tests\test_service_retry_policies_async.py:74:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
..\..\..\.venv\azure-cosmos\.venv_whl\Lib\site-packages\azure\core\tracing\decorator_async.py:119: in wrapper_use_tracer
return await func(*args, **kwargs)
..\..\..\.venv\azure-cosmos\.venv_whl\Lib\site-packages\azure\cosmos\aio\_container.py:397: in read_item
return await self.client_connection.ReadItem(document_link=doc_link, options=request_options, **kwargs)
..\..\..\.venv\azure-cosmos\.venv_whl\Lib\site-packages\azure\cosmos\aio\_cosmos_client_connection_async.py:1100: in ReadItem
return await self.Read(path, http_constants.ResourceType.Document, document_id, None, options, **kwargs)
..\..\..\.venv\azure-cosmos\.venv_whl\Lib\site-packages\azure\cosmos\aio\_cosmos_client_connection_async.py:1296: in Read
result, last_response_headers = await self.__Get(path, request_params, headers, **kwargs)
..\..\..\.venv\azure-cosmos\.venv_whl\Lib\site-packages\azure\cosmos\aio\_cosmos_client_connection_async.py:1320: in __Get
return await asynchronous_request.AsynchronousRequest(
..\..\..\.venv\azure-cosmos\.venv_whl\Lib\site-packages\azure\cosmos\aio\_asynchronous_request.py:241: in AsynchronousRequest
return await _retry_utility_async.ExecuteAsync(
..\..\..\.venv\azure-cosmos\.venv_whl\Lib\site-packages\azure\cosmos\aio\_retry_utility_async.py:288: in ExecuteAsync
_handle_service_request_retries(client, service_request_retry_policy, e, *args)
..\..\..\.venv\azure-cosmos\.venv_whl\Lib\site-packages\azure\cosmos\_retry_utility.py:354: in _handle_service_request_retries
raise exception
..\..\..\.venv\azure-cosmos\.venv_whl\Lib\site-packages\azure\cosmos\aio\_retry_utility_async.py:139: in ExecuteAsync
result = await ExecuteFunctionAsync(function, global_endpoint_manager, *args, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <test_service_retry_policies_async.TestServiceRetryPoliciesAsync.MockE
Check failure on line 1 in test_service_response_retry_policy_async
azure-pipelines / python - cosmos - ci
test_service_response_retry_policy_async
assert 1 == 3
+ where 1 = <test_service_retry_policies_async.TestServiceRetryPoliciesAsync.MockExecuteServiceResponseExceptionIgnoreQuery object at 0x000001D30FFC4D70>.counter
Raw output
self = <test_service_retry_policies_async.TestServiceRetryPoliciesAsync testMethod=test_service_response_retry_policy_async>
async def test_service_response_retry_policy_async(self):
# For ServiceResponseErrors, we only do cross region retries on read requests or on ClientConnectionErrors
# We also only do retries within the ConnectionRetryPolicy for the cases above
async with CosmosClient(self.host, self.masterKey) as mock_client:
db = mock_client.get_database_client(self.TEST_DATABASE_ID)
container = db.get_container_client(self.TEST_CONTAINER_ID)
created_item = await container.create_item({"id": str(uuid.uuid4()), "pk": str(uuid.uuid4())})
# Save the original function
self.original_execute_function = _retry_utility_async.ExecuteFunctionAsync
# Change the location cache to have 3 preferred read regions and 3 available read endpoints by location
original_location_cache = mock_client.client_connection._global_endpoint_manager.location_cache
original_location_cache.account_read_locations = [self.REGION1, self.REGION2, self.REGION3]
original_location_cache.available_read_regional_endpoints_by_locations = {
self.REGION1: self.REGIONAL_ENDPOINT,
self.REGION2: self.REGIONAL_ENDPOINT,
self.REGION3: self.REGIONAL_ENDPOINT}
original_location_cache.read_regional_routing_contexts = [self.REGIONAL_ENDPOINT, self.REGIONAL_ENDPOINT,
self.REGIONAL_ENDPOINT]
try:
# Mock the function to return the ClientConnectionError we retry
mf = self.MockExecuteServiceResponseExceptionIgnoreQuery(AttributeError,
None, self.original_execute_function)
_retry_utility_async.ExecuteFunctionAsync = mf
> await container.read_item(created_item['id'], created_item['pk'])
tests\test_service_retry_policies_async.py:166:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
..\..\..\.venv\azure-cosmos\.venv_sdist\Lib\site-packages\azure\core\tracing\decorator_async.py:119: in wrapper_use_tracer
return await func(*args, **kwargs)
..\..\..\.venv\azure-cosmos\.venv_sdist\Lib\site-packages\azure\cosmos\aio\_container.py:397: in read_item
return await self.client_connection.ReadItem(document_link=doc_link, options=request_options, **kwargs)
..\..\..\.venv\azure-cosmos\.venv_sdist\Lib\site-packages\azure\cosmos\aio\_cosmos_client_connection_async.py:1100: in ReadItem
return await self.Read(path, http_constants.ResourceType.Document, document_id, None, options, **kwargs)
..\..\..\.venv\azure-cosmos\.venv_sdist\Lib\site-packages\azure\cosmos\aio\_cosmos_client_connection_async.py:1296: in Read
result, last_response_headers = await self.__Get(path, request_params, headers, **kwargs)
..\..\..\.venv\azure-cosmos\.venv_sdist\Lib\site-packages\azure\cosmos\aio\_cosmos_client_connection_async.py:1320: in __Get
return await asynchronous_request.AsynchronousRequest(
..\..\..\.venv\azure-cosmos\.venv_sdist\Lib\site-packages\azure\cosmos\aio\_asynchronous_request.py:241: in AsynchronousRequest
return await _retry_utility_async.ExecuteAsync(
..\..\..\.venv\azure-cosmos\.venv_sdist\Lib\site-packages\azure\cosmos\aio\_retry_utility_async.py:307: in ExecuteAsync
_handle_service_response_retries(request, client, service_response_retry_policy, e, *args)
..\..\..\.venv\azure-cosmos\.venv_sdist\Lib\site-packages\azure\cosmos\_retry_utility.py:365: in _handle_service_response_retries
raise exception
..\..\..\.venv\azure-cosmos\.venv_sdist\Lib\site-packages\azure\cosmos\aio\_retry_utility_async.py:139: in ExecuteAsync
result = await ExecuteFunctionAsync(function, global_endpoint_manager, *args, **kwargs)
_ _ _ _ _ _