Skip to content

Commit 283246f

Browse files
authored
Use a Longer Delay to Test Search Clients Apply a New Date on Retry (Azure#27988)
1 parent 3b14f98 commit 283246f

File tree

3 files changed

+6
-0
lines changed

3 files changed

+6
-0
lines changed

sdk/search/azure-search-documents/src/test/java/com/azure/search/documents/SearchClientBuilderTests.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@
77
import com.azure.core.exception.HttpResponseException;
88
import com.azure.core.http.policy.ExponentialBackoffOptions;
99
import com.azure.core.http.policy.FixedDelay;
10+
import com.azure.core.http.policy.FixedDelayOptions;
1011
import com.azure.core.http.policy.HttpLogOptions;
1112
import com.azure.core.http.policy.RetryOptions;
1213
import com.azure.core.http.policy.RetryPolicy;
@@ -135,6 +136,7 @@ public void indexClientFreshDateOnRetry() throws MalformedURLException {
135136
.endpoint(searchEndpoint)
136137
.credential(searchApiKeyCredential)
137138
.indexName("test_builder")
139+
.retryOptions(new RetryOptions(new FixedDelayOptions(3, Duration.ofSeconds(1))))
138140
.httpClient(new SearchIndexClientBuilderTests.FreshDateTestClient())
139141
.buildAsyncClient();
140142

sdk/search/azure-search-documents/src/test/java/com/azure/search/documents/indexes/SearchIndexClientBuilderTests.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
import com.azure.core.http.HttpResponse;
1212
import com.azure.core.http.policy.ExponentialBackoffOptions;
1313
import com.azure.core.http.policy.FixedDelay;
14+
import com.azure.core.http.policy.FixedDelayOptions;
1415
import com.azure.core.http.policy.HttpLogOptions;
1516
import com.azure.core.http.policy.RetryOptions;
1617
import com.azure.core.http.policy.RetryPolicy;
@@ -124,6 +125,7 @@ public void serviceClientFreshDateOnRetry() throws MalformedURLException {
124125
SearchIndexAsyncClient searchIndexAsyncClient = new SearchIndexClientBuilder()
125126
.endpoint(searchEndpoint)
126127
.credential(searchApiKeyCredential)
128+
.retryOptions(new RetryOptions(new FixedDelayOptions(3, Duration.ofSeconds(1))))
127129
.httpClient(new FreshDateTestClient())
128130
.buildAsyncClient();
129131

sdk/search/azure-search-documents/src/test/java/com/azure/search/documents/indexes/SearchIndexerClientBuilderTests.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
import com.azure.core.http.HttpResponse;
1212
import com.azure.core.http.policy.ExponentialBackoffOptions;
1313
import com.azure.core.http.policy.FixedDelay;
14+
import com.azure.core.http.policy.FixedDelayOptions;
1415
import com.azure.core.http.policy.HttpLogOptions;
1516
import com.azure.core.http.policy.RetryOptions;
1617
import com.azure.core.http.policy.RetryPolicy;
@@ -124,6 +125,7 @@ public void serviceClientFreshDateOnRetry() throws MalformedURLException {
124125
SearchIndexerAsyncClient searchIndexerAsyncClient = new SearchIndexerClientBuilder()
125126
.endpoint(searchEndpoint)
126127
.credential(searchApiKeyCredential)
128+
.retryOptions(new RetryOptions(new FixedDelayOptions(3, Duration.ofSeconds(1))))
127129
.httpClient(new FreshDateTestClient())
128130
.buildAsyncClient();
129131

0 commit comments

Comments
 (0)