in src/main/java/org/opensearch/jobscheduler/scheduler/JobScheduler.java [100:122]
public boolean deschedule(String indexName, String id) {
JobSchedulingInfo jobInfo = this.scheduledJobInfo.getJobInfo(indexName, id);
if (jobInfo == null) {
log.debug("JobId {} doesn't not exist, skip descheduling.", id);
return true;
}
log.info("Descheduling jobId: {}", id);
jobInfo.setDescheduled(true);
jobInfo.setActualPreviousExecutionTime(null);
jobInfo.setExpectedPreviousExecutionTime(null);
Scheduler.ScheduledCancellable scheduledCancellable = jobInfo.getScheduledCancellable();
if (scheduledCancellable != null) {
if (scheduledCancellable.cancel()) {
this.scheduledJobInfo.removeJob(indexName, id);
} else {
return false;
}
}
return true;
}