add sync-up job in missing places

Signed-off-by: Bhavana Goud Ramaram <[email protected]>
opensearch-project · Dec 5, 2024 · 2d4e64a · 2d4e64a
1 parent 1af10ae
commit 2d4e64a
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/plugin/src/main/java/org/opensearch/ml/autoredeploy/MLModelAutoReDeployer.java b/plugin/src/main/java/org/opensearch/ml/autoredeploy/MLModelAutoReDeployer.java
@@ -186,6 +186,10 @@ private void triggerAutoDeployModels(List<String> addedNodes) {
                             modelAutoRedeployArrangements.add(modelAutoRedeployArrangement);
                     });
                 redeployAModel();
+            } else {
+                log.info("Could not find any models in the index, not performing auto reloading!");
+                startCronjobAndClearListener();
+                return;
             }
         }, e -> {
             if (e instanceof IndexNotFoundException) {
@@ -261,7 +265,7 @@ private void queryRunningModels(ActionListener<SearchResponse> listener) {
     private void triggerModelRedeploy(ModelAutoRedeployArrangement modelAutoRedeployArrangement) {
         if (modelAutoRedeployArrangement == null) {
             log.info("No more models in arrangement, skipping the redeployment");
-            redeployAModel();
+            startCronjobAndClearListener();
             return;
         }
         String modelId = modelAutoRedeployArrangement.getSearchResponse().getId();