diff --git a/sdk/storage/azure-storage-blob/azure/storage/blob/_shared/authentication.py b/sdk/storage/azure-storage-blob/azure/storage/blob/_shared/authentication.py index d04c1e4fb539..b11dc5757808 100644 --- a/sdk/storage/azure-storage-blob/azure/storage/blob/_shared/authentication.py +++ b/sdk/storage/azure-storage-blob/azure/storage/blob/_shared/authentication.py @@ -79,9 +79,7 @@ def _get_canonicalized_resource(self, request): uri_path = urlparse(request.http_request.url).path try: if isinstance(request.context.transport, AioHttpTransport) or \ - isinstance(getattr(request.context.transport, "_transport", None), AioHttpTransport) or \ - isinstance(getattr(getattr(request.context.transport, "_transport", None), "_transport", None), - AioHttpTransport): + isinstance(getattr(request.context.transport, "_transport", None), AioHttpTransport): uri_path = URL(uri_path) return '/' + self.account_name + str(uri_path) except TypeError: diff --git a/sdk/storage/azure-storage-blob/tests/recordings/test_common_blob_async.test_create_blob_with_equal_sign.yaml b/sdk/storage/azure-storage-blob/tests/recordings/test_common_blob_async.test_create_blob_with_equal_sign.yaml deleted file mode 100644 index 67ecf96393b5..000000000000 --- a/sdk/storage/azure-storage-blob/tests/recordings/test_common_blob_async.test_create_blob_with_equal_sign.yaml +++ /dev/null @@ -1,104 +0,0 @@ -interactions: -- request: - body: null - headers: - User-Agent: - - azsdk-python-storage-blob/12.4.0b1 Python/3.7.3 (Windows-10-10.0.19041-SP0) - x-ms-date: - - Thu, 27 Aug 2020 01:48:41 GMT - x-ms-version: - - '2019-12-12' - method: PUT - uri: https://storagename.blob.core.windows.net/utcontainer775c1685?timeout=5&restype=container - response: - body: - string: '' - headers: - content-length: '0' - date: Thu, 27 Aug 2020 01:48:40 GMT - etag: '"0x8D84A2B5357BF80"' - last-modified: Thu, 27 Aug 2020 01:48:41 GMT - server: Windows-Azure-Blob/1.0 Microsoft-HTTPAPI/2.0 - x-ms-version: '2019-12-12' - status: - code: 201 - message: Created - url: https://emilyeuap.blob.core.windows.net/utcontainer775c1685?timeout=5&restype=container -- request: - body: ??? - headers: - Content-Length: - - '3' - Content-Type: - - application/octet-stream - If-None-Match: - - '*' - User-Agent: - - azsdk-python-storage-blob/12.4.0b1 Python/3.7.3 (Windows-10-10.0.19041-SP0) - x-ms-blob-type: - - BlockBlob - x-ms-date: - - Thu, 27 Aug 2020 01:48:41 GMT - x-ms-version: - - '2019-12-12' - method: PUT - uri: https://storagename.blob.core.windows.net/utcontainer775c1685/=ques=tion! - response: - body: - string: '' - headers: - content-length: '0' - content-md5: DRsIw0hYkhvHxmKyKKy3ug== - date: Thu, 27 Aug 2020 01:48:40 GMT - etag: '"0x8D84A2B536556A6"' - last-modified: Thu, 27 Aug 2020 01:48:41 GMT - server: Windows-Azure-Blob/1.0 Microsoft-HTTPAPI/2.0 - x-ms-content-crc64: VtoDJyOMw/A= - x-ms-request-server-encrypted: 'true' - x-ms-version: '2019-12-12' - x-ms-version-id: '2020-08-27T01:48:41.6124582Z' - status: - code: 201 - message: Created - url: https://emilyeuap.blob.core.windows.net/utcontainer775c1685/=ques=tion! -- request: - body: null - headers: - Accept: - - application/xml - User-Agent: - - azsdk-python-storage-blob/12.4.0b1 Python/3.7.3 (Windows-10-10.0.19041-SP0) - x-ms-date: - - Thu, 27 Aug 2020 01:48:41 GMT - x-ms-range: - - bytes=0-33554431 - x-ms-version: - - '2019-12-12' - method: GET - uri: https://storagename.blob.core.windows.net/utcontainer775c1685/=ques=tion! - response: - body: - string: ??? - headers: - accept-ranges: bytes - content-length: '3' - content-range: bytes 0-2/3 - content-type: application/octet-stream - date: Thu, 27 Aug 2020 01:48:41 GMT - etag: '"0x8D84A2B536556A6"' - last-modified: Thu, 27 Aug 2020 01:48:41 GMT - server: Windows-Azure-Blob/1.0 Microsoft-HTTPAPI/2.0 - x-ms-blob-content-md5: DRsIw0hYkhvHxmKyKKy3ug== - x-ms-blob-type: BlockBlob - x-ms-creation-time: Thu, 27 Aug 2020 01:48:41 GMT - x-ms-is-current-version: 'true' - x-ms-lease-state: available - x-ms-lease-status: unlocked - x-ms-server-encrypted: 'true' - x-ms-version: '2019-12-12' - x-ms-version-id: '2020-08-27T01:48:41.6124582Z' - status: - code: 206 - message: Partial Content - url: https://emilyeuap.blob.core.windows.net/utcontainer775c1685/=ques=tion! -version: 1 diff --git a/sdk/storage/azure-storage-blob/tests/test_common_blob_async.py b/sdk/storage/azure-storage-blob/tests/test_common_blob_async.py index b2a7bc6235d8..c99a9a9fc152 100644 --- a/sdk/storage/azure-storage-blob/tests/test_common_blob_async.py +++ b/sdk/storage/azure-storage-blob/tests/test_common_blob_async.py @@ -272,24 +272,6 @@ async def test_create_blob_with_question_mark(self, resource_group, location, st content = data.decode('utf-8') self.assertEqual(content, blob_data) - @GlobalStorageAccountPreparer() - @AsyncStorageTestCase.await_prepared_test - async def test_create_blob_with_equal_sign(self, resource_group, location, storage_account, storage_account_key): - # Arrange - await self._setup(storage_account, storage_account_key) - blob_name = '=ques=tion!' - blob_data = u'???' - - # Act - blob = self.bsc.get_blob_client(self.container_name, blob_name) - await blob.upload_blob(blob_data) - - # Assert - stream = await blob.download_blob() - data = await stream.readall() - self.assertIsNotNone(data) - content = data.decode('utf-8') - self.assertEqual(content, blob_data) @GlobalStorageAccountPreparer() @AsyncStorageTestCase.await_prepared_test diff --git a/sdk/storage/azure-storage-file-datalake/azure/storage/filedatalake/_shared/authentication.py b/sdk/storage/azure-storage-file-datalake/azure/storage/filedatalake/_shared/authentication.py index d04c1e4fb539..b11dc5757808 100644 --- a/sdk/storage/azure-storage-file-datalake/azure/storage/filedatalake/_shared/authentication.py +++ b/sdk/storage/azure-storage-file-datalake/azure/storage/filedatalake/_shared/authentication.py @@ -79,9 +79,7 @@ def _get_canonicalized_resource(self, request): uri_path = urlparse(request.http_request.url).path try: if isinstance(request.context.transport, AioHttpTransport) or \ - isinstance(getattr(request.context.transport, "_transport", None), AioHttpTransport) or \ - isinstance(getattr(getattr(request.context.transport, "_transport", None), "_transport", None), - AioHttpTransport): + isinstance(getattr(request.context.transport, "_transport", None), AioHttpTransport): uri_path = URL(uri_path) return '/' + self.account_name + str(uri_path) except TypeError: diff --git a/sdk/storage/azure-storage-file-share/azure/storage/fileshare/_shared/authentication.py b/sdk/storage/azure-storage-file-share/azure/storage/fileshare/_shared/authentication.py index d04c1e4fb539..b11dc5757808 100644 --- a/sdk/storage/azure-storage-file-share/azure/storage/fileshare/_shared/authentication.py +++ b/sdk/storage/azure-storage-file-share/azure/storage/fileshare/_shared/authentication.py @@ -79,9 +79,7 @@ def _get_canonicalized_resource(self, request): uri_path = urlparse(request.http_request.url).path try: if isinstance(request.context.transport, AioHttpTransport) or \ - isinstance(getattr(request.context.transport, "_transport", None), AioHttpTransport) or \ - isinstance(getattr(getattr(request.context.transport, "_transport", None), "_transport", None), - AioHttpTransport): + isinstance(getattr(request.context.transport, "_transport", None), AioHttpTransport): uri_path = URL(uri_path) return '/' + self.account_name + str(uri_path) except TypeError: diff --git a/sdk/storage/azure-storage-queue/azure/storage/queue/_shared/authentication.py b/sdk/storage/azure-storage-queue/azure/storage/queue/_shared/authentication.py index d04c1e4fb539..b11dc5757808 100644 --- a/sdk/storage/azure-storage-queue/azure/storage/queue/_shared/authentication.py +++ b/sdk/storage/azure-storage-queue/azure/storage/queue/_shared/authentication.py @@ -79,9 +79,7 @@ def _get_canonicalized_resource(self, request): uri_path = urlparse(request.http_request.url).path try: if isinstance(request.context.transport, AioHttpTransport) or \ - isinstance(getattr(request.context.transport, "_transport", None), AioHttpTransport) or \ - isinstance(getattr(getattr(request.context.transport, "_transport", None), "_transport", None), - AioHttpTransport): + isinstance(getattr(request.context.transport, "_transport", None), AioHttpTransport): uri_path = URL(uri_path) return '/' + self.account_name + str(uri_path) except TypeError: