Skip to content

Commit

Permalink
Allow system index warning in OpenSearchRestTestCase.refreshAllIndices (
Browse files Browse the repository at this point in the history
#14635)

* Allow system index warning

Signed-off-by: Craig Perkins <[email protected]>

* Add to CHANGELOG

Signed-off-by: Craig Perkins <[email protected]>

* Address code review comments

Signed-off-by: Craig Perkins <[email protected]>

---------

Signed-off-by: Craig Perkins <[email protected]>
  • Loading branch information
cwperks authored Jul 5, 2024
1 parent 74230b7 commit f14b5c8
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 4 deletions.
1 change: 1 addition & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -36,6 +36,7 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
- Make the class CommunityIdProcessor final ([#14448](https:/opensearch-project/OpenSearch/pull/14448))
- Allow @InternalApi annotation on classes not meant to be constructed outside of the OpenSearch core ([#14575](https:/opensearch-project/OpenSearch/pull/14575))
- Add @InternalApi annotation to japicmp exclusions ([#14597](https:/opensearch-project/OpenSearch/pull/14597))
- Allow system index warning in OpenSearchRestTestCase.refreshAllIndices ([#14635](https:/opensearch-project/OpenSearch/pull/14635))

### Deprecated

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -708,11 +708,15 @@ protected void refreshAllIndices() throws IOException {
requestOptions.setWarningsHandler(warnings -> {
if (warnings.isEmpty()) {
return false;
} else if (warnings.size() > 1) {
return true;
} else {
return warnings.get(0).startsWith("this request accesses system indices:") == false;
}
boolean allSystemIndexWarnings = true;
for (String warning : warnings) {
if (!warning.startsWith("this request accesses system indices:")) {
allSystemIndexWarnings = false;
break;
}
}
return !allSystemIndexWarnings;
});
refreshRequest.setOptions(requestOptions);
client().performRequest(refreshRequest);
Expand Down

0 comments on commit f14b5c8

Please sign in to comment.