From 43a2c5053e90c0a12d404d873aa1c5f45e47c96d Mon Sep 17 00:00:00 2001
From: bowenlan-amzn <bowenlan23@gmail.com>
Date: Thu, 12 Oct 2023 10:53:59 -0700
Subject: [PATCH] small fix

Signed-off-by: bowenlan-amzn <bowenlan23@gmail.com>
---
 .../ManagedIndexRunner.kt                     | 32 ++++++++++++-------
 1 file changed, 21 insertions(+), 11 deletions(-)

diff --git a/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexRunner.kt b/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexRunner.kt
index 5a80230a5..ef19e7ed3 100644
--- a/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexRunner.kt
+++ b/src/main/kotlin/org/opensearch/indexmanagement/indexstatemanagement/ManagedIndexRunner.kt
@@ -809,19 +809,29 @@ object ManagedIndexRunner :
 
     private suspend fun publishErrorNotification(policy: Policy, metadata: ManagedIndexMetaData): ManagedIndexMetaData {
         return try {
-            // if the policy has no error_notification this will do nothing otherwise it will try to send the configured error message
-            policy.errorNotification?.run {
-                errorNotificationRetryPolicy.retry(logger) {
-                    val compiledMessage = compileTemplate(messageTemplate, metadata)
-                    destination?.buildLegacyBaseMessage(null, compiledMessage)?.publishLegacyNotification(client)
-                    channel?.sendNotification(client, ErrorNotification.CHANNEL_TITLE, metadata, compiledMessage, policy.user)
+            val errorNotification = policy.errorNotification
+            if (errorNotification != null) {
+                policy.errorNotification.run {
+                    errorNotificationRetryPolicy.retry(logger) {
+                        val compiledMessage = compileTemplate(messageTemplate, metadata)
+                        destination?.buildLegacyBaseMessage(null, compiledMessage)?.publishLegacyNotification(client)
+                        channel?.sendNotification(
+                            client,
+                            ErrorNotification.CHANNEL_TITLE,
+                            metadata,
+                            compiledMessage,
+                            policy.user
+                        )
+                    }
                 }
+                val message = "Successfully published error notification [index = ${metadata.index}]"
+                logger.info(message)
+                val mutableInfo = metadata.info?.toMutableMap() ?: mutableMapOf()
+                mutableInfo["error_notification"] = message
+                metadata.copy(info = mutableInfo.toMap())
+            } else {
+                return metadata
             }
-            val message = "Successfully published error notification [index = ${metadata.index}]"
-            logger.info(message)
-            val mutableInfo = metadata.info?.toMutableMap() ?: mutableMapOf()
-            mutableInfo["error_notification"] = message
-            metadata.copy(info = mutableInfo.toMap())
         } catch (e: Exception) {
             logger.error("Failed to publish error notification", e)
             val errorMessage = e.message ?: "Failed to publish error notification"