@Test
  public void testUploadDocClientException() throws Exception {
    when(mockCosmosAsyncContainer.upsertItem(any(), any(), any())).thenReturn(Mono.error(mockNotFoundCosmosException));
    expectCloudStorageException(() -> uploadDefaultBlob(), CosmosException.class);
  }
Test upload when doc client throws exception.
ambry-cloud/src/test/java/com/github/ambry/cloud/azure/AzureCloudDestinationTest.java