fix(os): upsert_doc doc_id var + immediate refresh for single-doc writes

app/stores/opensearch.py

@@ -129,14 +129,17 @@ class OpenSearchStore:
 
     async def index_doc(self, index: str, doc: dict, doc_id: Optional[str] = None) -> str:
         _id = doc_id or doc.get("account_id") or doc.get("contact_id") or doc.get("event_id") or doc.get("doc_id") or str(uuid.uuid4())
-        res = await self.client().put(f"/{self._index(index)}/_doc/{_id}", json=doc)
+        res = await self.client().put(
+            f"/{self._index(index)}/_doc/{_id}", json=doc,
+            params={"refresh": "true"},
+        )
         res.raise_for_status()
         return _id
 
     async def upsert_doc(self, index: str, doc: dict, doc_id: str) -> str:
         res = await self.client().put(
-            f"/{self._index(index)}/_doc/{_id}", json=doc,
-            params={"refresh": "false"},
+            f"/{self._index(index)}/_doc/{doc_id}", json=doc,
+            params={"refresh": "true"},
         )
         res.raise_for_status()
         return doc_id