Skip to content

Commit

Permalink
fix spotless
Browse files Browse the repository at this point in the history
Signed-off-by: Hailong Cui <[email protected]>
  • Loading branch information
Hailong-am committed Nov 29, 2023
1 parent fe4dddd commit 6e051cc
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -300,7 +300,7 @@ public void deleteInteraction(String interactionId, ActionListener<Boolean> list
bulkRequest.add(new DeleteRequest(indexName, interactionId));

innerGetTraces(interactionId, ActionListener.wrap(traces -> {
traces.forEach(trace-> bulkRequest.add(new DeleteRequest(indexName, trace.getId())));
traces.forEach(trace -> bulkRequest.add(new DeleteRequest(indexName, trace.getId())));

innerDeleteInteraction(bulkRequest, interactionId, listener);
}, e -> {
Expand All @@ -310,7 +310,7 @@ public void deleteInteraction(String interactionId, ActionListener<Boolean> list
}

@VisibleForTesting
void innerDeleteInteraction(BulkRequest bulkRequest, String interactionId, ActionListener<Boolean> listener) {
void innerDeleteInteraction(BulkRequest bulkRequest, String interactionId, ActionListener<Boolean> listener) {
try (ThreadContext.StoredContext ignored = client.threadPool().getThreadContext().stashContext()) {
ActionListener<BulkResponse> al = ActionListener.wrap(bulkResponse -> {
if (bulkResponse != null && bulkResponse.hasFailures()) {
Expand Down

0 comments on commit 6e051cc

Please sign in to comment.