yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-08-30 03:46:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

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

Browse Source
This commit is contained in:
Imri Paran 2024-12-19 14:03:01 +01:00 committed by GitHub
parent efbdf21098
commit 6fab88a3d1
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
openmetadata-service/src/main/java/org/openmetadata/service/apps/scheduler/AppScheduler.java
View File

@ -38,6 +38,7 @@ import org.quartz.Trigger;
import org.quartz.TriggerBuilder; import org.quartz.TriggerBuilder;
import org.quartz.TriggerKey; import org.quartz.TriggerKey;
import org.quartz.impl.StdSchedulerFactory; import org.quartz.impl.StdSchedulerFactory;
import org.quartz.impl.matchers.GroupMatcher;
@Slf4j @Slf4j
public class AppScheduler { public class AppScheduler {
@ -93,10 +94,32 @@ public class AppScheduler {
.getListenerManager() .getListenerManager()
.addJobListener(new OmAppJobListener(dao), jobGroupEquals(APPS_JOB_GROUP)); .addJobListener(new OmAppJobListener(dao), jobGroupEquals(APPS_JOB_GROUP));
this.resetErrorTriggers();
// Start Scheduler // Start Scheduler
this.scheduler.start(); 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( public static void initialize(
OpenMetadataApplicationConfig config, CollectionDAO dao, SearchRepository searchClient) OpenMetadataApplicationConfig config, CollectionDAO dao, SearchRepository searchClient)
throws SchedulerException { throws SchedulerException {