From 4fcf90ac00fa6cc192a078517c55c8df1fbc6fb3 Mon Sep 17 00:00:00 2001 From: Aditya <60684641+0x0elliot@users.noreply.github.com> Date: Tue, 30 Jun 2026 01:16:19 +0530 Subject: [PATCH] fix: refresh OpenSearch deletes for immediate read-after-delete --- db-connector.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/db-connector.go b/db-connector.go index abafea5f..d0390494 100755 --- a/db-connector.go +++ b/db-connector.go @@ -5817,6 +5817,8 @@ func DeleteKey(ctx context.Context, entity string, value string, orgIdList ...st resp, err := project.Es.Document.Delete(ctx, opensearchapi.DocumentDeleteReq{ Index: strings.ToLower(GetESIndexPrefix(entity)), DocumentID: value, + // Refresh so the delete is immediately reflected in reads; matches indexEs(). + Params: opensearchapi.DocumentDeleteParams{Refresh: "true"}, }) if err != nil {