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 index f54a46531b..e36c296066 100644 --- a/memory/src/main/java/org/opensearch/ml/memory/index/ConversationMetaIndex.java +++ b/memory/src/main/java/org/opensearch/ml/memory/index/ConversationMetaIndex.java @@ -297,7 +297,6 @@ public void checkAccess(String conversationId, ActionListener listener) log.error("Failed to refresh conversations index during check access ", e); internalListener.onFailure(e); })); - // client.get(getRequest, al); } catch (Exception e) { listener.onFailure(e); } diff --git a/memory/src/main/java/org/opensearch/ml/memory/index/OpenSearchConversationalMemoryHandler.java b/memory/src/main/java/org/opensearch/ml/memory/index/OpenSearchConversationalMemoryHandler.java index b0947069ae..6b33533ee2 100644 --- a/memory/src/main/java/org/opensearch/ml/memory/index/OpenSearchConversationalMemoryHandler.java +++ b/memory/src/main/java/org/opensearch/ml/memory/index/OpenSearchConversationalMemoryHandler.java @@ -250,7 +250,7 @@ public ActionFuture> getConversations(int maxResults) { public void deleteConversation(String conversationId, ActionListener listener) { StepListener accessListener = new StepListener<>(); conversationMetaIndex.checkAccess(conversationId, accessListener); - log.info("DELETING CID " + conversationId); + log.info("DELETING CONVERSATION " + conversationId); accessListener.whenComplete(access -> { if (access) { StepListener metaDeleteListener = new StepListener<>(); @@ -265,7 +265,7 @@ public void deleteConversation(String conversationId, ActionListener li ); metaDeleteListener.whenComplete(metaDeleteResult -> { - log.info("SUCCESSFUL DELETION OF CID " + conversationId); + log.info("SUCCESSFUL DELETION OF CONVERSATION " + conversationId); listener.onResponse(metaDeleteResult && interactionsListener.result()); }, listener::onFailure);