diff --git a/api/cron/scheduler.go b/api/cron/scheduler.go index 9a2de7450..85b27398b 100644 --- a/api/cron/scheduler.go +++ b/api/cron/scheduler.go @@ -19,7 +19,8 @@ func NewJobScheduler() *JobScheduler { // ScheduleJob schedules the execution of a job via a runner func (scheduler *JobScheduler) ScheduleJob(runner portainer.JobRunner) error { - return scheduler.cron.AddJob(runner.GetSchedule().CronExpression, runner) + _, err := scheduler.cron.AddJob(runner.GetSchedule().CronExpression, runner) + return err } // UpdateSystemJobSchedule updates the first occurence of the specified @@ -35,7 +36,7 @@ func (scheduler *JobScheduler) UpdateSystemJobSchedule(jobType portainer.JobType for _, entry := range cronEntries { if entry.Job.(portainer.JobRunner).GetSchedule().JobType == jobType { - err := newCron.AddJob(newCronExpression, entry.Job) + _, err := newCron.AddJob(newCronExpression, entry.Job) if err != nil { return err } @@ -69,7 +70,7 @@ func (scheduler *JobScheduler) UpdateJobSchedule(runner portainer.JobRunner) err jobRunner = entry.Job } - err := newCron.AddJob(runner.GetSchedule().CronExpression, jobRunner) + _, err := newCron.AddJob(runner.GetSchedule().CronExpression, jobRunner) if err != nil { return err }