change the order of stopSchedule

This commit is contained in:
yashsinghcodes
2025-11-10 13:54:14 +05:30
parent 2d85c8aac0
commit 2dc1966d08
+25 -16
View File
@@ -1505,30 +1505,39 @@ func stopScheduleGCP(resp http.ResponseWriter, request *http.Request) {
return return
} }
func deleteSchedule(ctx context.Context, id string) error { func deleteKeySchedule(ctx context.Context, id string) error {
log.Printf("[DEBUG] Should stop schedule %s!", id)
err := shuffle.DeleteKey(ctx, "schedules", id) err := shuffle.DeleteKey(ctx, "schedules", id)
if err != nil { if err != nil {
log.Printf("[ERROR] Failed to delete schedule: %s", err)
return err return err
}
return nil
}
func deleteSchedule(ctx context.Context, id string) error {
log.Printf("[DEBUG] Should stop schedule %s!", id)
if value, exists := scheduledJobs[id]; exists {
// Stops the schedule properly
value.Lock()
} else { } else {
if value, exists := scheduledJobs[id]; exists { // FIXME - allow it to kind of stop anyway?
// Stops the schedule properly if j, ok := cronJobs[id]; ok {
value.Lock() err := CronScheduler.RemoveByID(j)
} else { if err != nil {
// FIXME - allow it to kind of stop anyway? log.Printf("[ERROR] Failed to remove the scheduler %s", err)
if j, ok := cronJobs[id]; ok { return err
err := CronScheduler.RemoveByID(j)
if err != nil {
log.Printf("[ERROR] Failed to remove the scheduler %s", err)
return err
}
} else {
return errors.New("Can't find the schedule.")
} }
} else {
// Just stop and delete anyway if not in memory
deleteKeySchedule(ctx, id)
return errors.New("Can't find the schedule.")
} }
} }
err := deleteKeySchedule(ctx, id)
if err != nil {
log.Printf("[ERROR] Failed to stop schedule in db %s: %s", id, err)
return err
}
return nil return nil
} }