From 44984b588402a7ab6d1bc73e6cd0685b0a643eb8 Mon Sep 17 00:00:00 2001 From: Rakshith Bhyravabhotla Date: Wed, 16 Oct 2019 17:12:27 -0700 Subject: [PATCH 1/2] Stop modifying internal body --- .../azure/storage/blob/_shared/policies_async.py | 1 - 1 file changed, 1 deletion(-) diff --git a/sdk/storage/azure-storage-blob/azure/storage/blob/_shared/policies_async.py b/sdk/storage/azure-storage-blob/azure/storage/blob/_shared/policies_async.py index 7337a976109e..c0a44767b177 100644 --- a/sdk/storage/azure-storage-blob/azure/storage/blob/_shared/policies_async.py +++ b/sdk/storage/azure-storage-blob/azure/storage/blob/_shared/policies_async.py @@ -54,7 +54,6 @@ async def send(self, request): response = await self.next.send(request) await response.http_response.load_body() - response.http_response.internal_response.body = response.http_response.body() will_retry = is_retry(response, request.context.options.get('mode')) if not will_retry and download_stream_current is not None: From 5586c633251cb5b4fd823f93a17ff98554b98551 Mon Sep 17 00:00:00 2001 From: Rakshith Bhyravabhotla Date: Wed, 16 Oct 2019 17:47:07 -0700 Subject: [PATCH 2/2] Replicate for queues and files too --- .../azure/storage/file/_shared/policies_async.py | 1 - .../azure/storage/queue/_shared/policies_async.py | 1 - 2 files changed, 2 deletions(-) diff --git a/sdk/storage/azure-storage-file/azure/storage/file/_shared/policies_async.py b/sdk/storage/azure-storage-file/azure/storage/file/_shared/policies_async.py index 7337a976109e..c0a44767b177 100644 --- a/sdk/storage/azure-storage-file/azure/storage/file/_shared/policies_async.py +++ b/sdk/storage/azure-storage-file/azure/storage/file/_shared/policies_async.py @@ -54,7 +54,6 @@ async def send(self, request): response = await self.next.send(request) await response.http_response.load_body() - response.http_response.internal_response.body = response.http_response.body() will_retry = is_retry(response, request.context.options.get('mode')) if not will_retry and download_stream_current is not None: diff --git a/sdk/storage/azure-storage-queue/azure/storage/queue/_shared/policies_async.py b/sdk/storage/azure-storage-queue/azure/storage/queue/_shared/policies_async.py index 7337a976109e..c0a44767b177 100644 --- a/sdk/storage/azure-storage-queue/azure/storage/queue/_shared/policies_async.py +++ b/sdk/storage/azure-storage-queue/azure/storage/queue/_shared/policies_async.py @@ -54,7 +54,6 @@ async def send(self, request): response = await self.next.send(request) await response.http_response.load_body() - response.http_response.internal_response.body = response.http_response.body() will_retry = is_retry(response, request.context.options.get('mode')) if not will_retry and download_stream_current is not None: