fix(error-apps): reset apps in error state (#19052)

open-metadata · Dec 19, 2024 · 6fab88a · 6fab88a
1 parent efbdf21
commit 6fab88a
Showing 1 changed file with 23 additions and 0 deletions.
diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/apps/scheduler/AppScheduler.java b/openmetadata-service/src/main/java/org/openmetadata/service/apps/scheduler/AppScheduler.java
@@ -38,6 +38,7 @@
 import org.quartz.TriggerBuilder;
 import org.quartz.TriggerKey;
 import org.quartz.impl.StdSchedulerFactory;
+import org.quartz.impl.matchers.GroupMatcher;
 
 @Slf4j
 public class AppScheduler {
@@ -93,10 +94,32 @@ private AppScheduler(
         .getListenerManager()
         .addJobListener(new OmAppJobListener(dao), jobGroupEquals(APPS_JOB_GROUP));
 
+    this.resetErrorTriggers();
+
     // Start Scheduler
     this.scheduler.start();
   }
 
+  private void resetErrorTriggers() {
+    try {
+      scheduler
+          .getTriggerKeys(GroupMatcher.anyGroup())
+          .forEach(
+              triggerKey -> {
+                try {
+                  if (scheduler.getTriggerState(triggerKey) == Trigger.TriggerState.ERROR) {
+                    LOG.info("Resetting trigger {} from error state", triggerKey);
+                    scheduler.resetTriggerFromErrorState(triggerKey);
+                  }
+                } catch (SchedulerException e) {
+                  throw new RuntimeException(e);
+                }
+              });
+    } catch (SchedulerException ex) {
+      LOG.error("Failed to reset failed triggers", ex);
+    }
+  }
+
   public static void initialize(
       OpenMetadataApplicationConfig config, CollectionDAO dao, SearchRepository searchClient)
       throws SchedulerException {