yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-11-04 04:29:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch '1.6.2' of github.com:open-metadata/OpenMetadata into 1.6.2

Browse Source
This commit is contained in:
Pablo Takara 2025-01-02 08:07:48 +01:00
commit be2c9c802a
No known key found for this signature in database
GPG Key ID: 63381DDFBB2BF725
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.TriggerKey;
import org.quartz.impl.StdSchedulerFactory;
import org.quartz.impl.matchers.GroupMatcher;
@Slf4j
public class AppScheduler {
@ -93,10 +94,32 @@ public class 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 {