es execute fail throw exception

dumasd · Dec 9, 2024 · 4655901 · 4655901
1 parent 3a0a85b
commit 4655901
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/...main/java/io/jenkins/plugins/configops/elasticsearch/ElasticsearchChangeSetApplyStep.java b/...main/java/io/jenkins/plugins/configops/elasticsearch/ElasticsearchChangeSetApplyStep.java
@@ -12,6 +12,7 @@
 import io.jenkins.plugins.configops.model.dto.ElasticsearchChangeSetDTO;
 import io.jenkins.plugins.configops.model.req.ElasticsearchChangeSetReq;
 import io.jenkins.plugins.configops.utils.ConfigOpsClient;
+import io.jenkins.plugins.configops.utils.ConfigOpsException;
 import io.jenkins.plugins.configops.utils.Constants;
 import io.jenkins.plugins.configops.utils.Logger;
 import io.jenkins.plugins.configops.utils.Utils;
@@ -159,9 +160,15 @@ protected List<ElasticsearchChangeSetDTO> run() throws Exception {
                     }
                 }
             }
+
             logger.log(
                     "Run summary\nChangeset num:       %d\nSuccess change num:  %d\nFailure change num:  %d\nSkip change num:     %d",
                     changeSetNum, successNum, failNum, skipNum);
+
+            if (failNum > 0) {
+                throw new ConfigOpsException("Run elasticsearch changelog unsuccessful");
+            }
+
             return result;
         }
     }