diff --git a/db-connector.go b/db-connector.go
index 24dad359..abafea5f 100755
--- a/db-connector.go
+++ b/db-connector.go
@@ -15116,6 +15116,8 @@ func SetDatastoreKeyBulk(ctx context.Context, allKeys []CacheKeyData) ([]Datasto
 		resp, err := project.Es.Bulk(ctx, opensearchapi.BulkReq{
 			Body:  bytes.NewReader(buf.Bytes()),
 			Index: strings.ToLower(GetESIndexPrefix(nameKey)),
+			// Refresh for immediate read-after-write; matches indexEs().
+			Params: opensearchapi.BulkParams{Refresh: "true"},
 		})
 
 		res := resp.Inspect().Response