diff --git a/rag/utils/opensearch_conn.py b/rag/utils/opensearch_conn.py
index 4fd09b782..b53a6123f 100644
--- a/rag/utils/opensearch_conn.py
+++ b/rag/utils/opensearch_conn.py
@@ -329,7 +329,7 @@ class OSConnection(DocStoreConnection):
             chunkId = condition["id"]
             for i in range(ATTEMPT_TIME):
                 try:
-                    self.os.update(index=indexName, id=chunkId, body=doc)
+                    self.os.update(index=indexName, id=chunkId, body={"doc":doc})
                     return True
                 except Exception as e:
                     logger.exception(