add workflow_id field in alert mapping (opensearch-project#969) (open…

…search-project#970) Signed-off-by: Surya Sashank Nistala <[email protected]> (cherry picked from commit 62d2524) Co-authored-by: Surya Sashank Nistala <[email protected]>
amitgalitz · Jun 22, 2023 · 4954387 · 4954387
1 parent 96365c6
commit 4954387
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/AlertService.kt b/alerting/src/main/kotlin/org/opensearch/alerting/AlertService.kt
@@ -550,6 +550,14 @@ class AlertService(
                         throw IllegalStateException("Unexpected attempt to save ${alert.state} alert: $alert")
                     }
                 }
+                Alert.State.AUDIT -> {
+                    listOf<DocWriteRequest<*>>(
+                        IndexRequest(alertsIndex)
+                            .routing(alert.monitorId)
+                            .source(alert.toXContentWithUser(XContentFactory.jsonBuilder()))
+                            .id(if (alert.id != Alert.NO_ID) alert.id else null)
+                    )
+                }
                 Alert.State.DELETED -> {
                     throw IllegalStateException("Unexpected attempt to save ${alert.state} alert: $alert")
                 }

diff --git a/alerting/src/main/resources/org/opensearch/alerting/alerts/alert_mapping.json b/alerting/src/main/resources/org/opensearch/alerting/alerts/alert_mapping.json
@@ -13,6 +13,9 @@
     "monitor_id": {
       "type": "keyword"
     },
+    "workflow_id": {
+      "type": "keyword"
+    },
     "monitor_version": {
       "type": "long"
     },