simplify

Author: dnhatn

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/async/AsyncResultsService.java

@@ -117,19 +117,11 @@ private void getSearchResponseFromTask(
             if (expirationTimeMillis != -1) {
                 task.setExpirationTime(expirationTimeMillis);
             }
-            boolean added = addCompletionListener.apply(task, listener.delegateFailure((l, response) -> {
-                // If the task expiration is updated after the document was created with an earlier expiration time,
-                // we should TRY to update the document's expiration time here.
-                if (updateInitialResultsInStore == false && expirationTimeMillis != -1) {
-                    store.updateExpirationTime(
-                        searchId.getDocId(),
-                        expirationTimeMillis,
-                        ActionListener.running(() -> sendFinalResponse(request, response, nowInMillis, l))
-                    );
-                } else {
-                    sendFinalResponse(request, response, nowInMillis, l);
-                }
-            }), request.getWaitForCompletionTimeout());
+            boolean added = addCompletionListener.apply(
+                task,
+                listener.delegateFailure((l, response) -> sendFinalResponse(request, response, nowInMillis, l)),
+                request.getWaitForCompletionTimeout()
+            );
             if (added == false) {
                 // the task must have completed, since we cannot add a completion listener
                 assert store.getTaskAndCheckAuthentication(taskManager, searchId, asyncTaskClass) == null;