diff --git a/job.go b/job.go index 60c96dc..e3a6d7e 100644 --- a/job.go +++ b/job.go @@ -88,7 +88,7 @@ func rescheduleJob(jobID64 int64, status int32, schedule time.Time) error { } defer stmt.Close() - _, err = stmt.Exec(time.Now(), status, jobID64) + _, err = stmt.Exec(schedule, status, jobID64) s := fmt.Sprintf("rescheduleJob, update obj_job(%d)", jobID64) logOnError(err, s) if err != nil {