fix async return value problem

Signed-off-by: HenryL27 <[email protected]>
HenryL27 · Oct 12, 2023 · 0d116af · 0d116af
1 parent e379420
commit 0d116af
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/memory/src/main/java/org/opensearch/ml/memory/index/ConversationMetaIndex.java b/memory/src/main/java/org/opensearch/ml/memory/index/ConversationMetaIndex.java
@@ -173,6 +173,7 @@ public void createConversation(ActionListener<String> listener) {
  public void getConversations(int from, int maxResults, ActionListener<List<ConversationMeta>> listener) {
  if (!clusterService.state().metadata().hasIndex(indexName)) {
  listener.onResponse(List.of());
+ return;
  }
  SearchRequest request = Requests.searchRequest(indexName);
  String userstr = client.threadPool().getThreadContext().getTransient(ConfigConstants.OPENSEARCH_SECURITY_USER_INFO_THREAD_CONTEXT);
@@ -226,6 +227,7 @@ public void getConversations(int maxResults, ActionListener<List<ConversationMet
  public void deleteConversation(String conversationId, ActionListener<Boolean> listener) {
  if (!clusterService.state().metadata().hasIndex(indexName)) {
  listener.onResponse(true);
+ return;
  }
  DeleteRequest delRequest = Requests.deleteRequest(indexName).id(conversationId);
  String userstr = client.threadPool().getThreadContext().getTransient(ConfigConstants.OPENSEARCH_SECURITY_USER_INFO_THREAD_CONTEXT);