Skip to content

Commit

Permalink
Fixed large file live test to add policy per call instead of per retry (
Browse files Browse the repository at this point in the history
#17593)

Co-authored-by: gapra <gapra@microsoft.com>
  • Loading branch information
gapra-msft and gapra-msft authored Nov 16, 2020
1 parent c97aee7 commit 9215dcc
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@ package com.azure.storage.blob
import com.azure.core.http.HttpMethod
import com.azure.core.http.HttpPipelineCallContext
import com.azure.core.http.HttpPipelineNextPolicy
import com.azure.core.http.HttpPipelinePosition
import com.azure.core.http.HttpRequest
import com.azure.core.http.HttpResponse
import com.azure.core.http.policy.HttpPipelinePolicy
Expand Down Expand Up @@ -383,5 +384,9 @@ class LargeBlobTest extends APISpec {
request.getUrl().getPath().endsWith(blobName) &&
request.getUrl().getQuery() == null
}

HttpPipelinePosition getPipelinePosition() {
return HttpPipelinePosition.PER_CALL;
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@ package com.azure.storage.file.datalake

import com.azure.core.http.HttpPipelineCallContext
import com.azure.core.http.HttpPipelineNextPolicy
import com.azure.core.http.HttpPipelinePosition
import com.azure.core.http.HttpRequest
import com.azure.core.http.HttpResponse
import com.azure.core.http.policy.HttpPipelinePolicy
Expand Down Expand Up @@ -273,5 +274,9 @@ class LargeFileTest extends APISpec{
private boolean isFlushRequest(HttpRequest request) {
return request.url.getQuery() != null && request.url.getQuery().contains("action=flush")
}

HttpPipelinePosition getPipelinePosition() {
return HttpPipelinePosition.PER_CALL;
}
}
}

0 comments on commit 9215dcc

Please sign in to comment.