test
This commit is contained in:
parent
49f63f4faf
commit
f7120953f3
2
job.go
2
job.go
@ -88,7 +88,7 @@ func rescheduleJob(jobID64 int64, status int32, schedule time.Time) error {
|
|||||||
}
|
}
|
||||||
defer stmt.Close()
|
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)
|
s := fmt.Sprintf("rescheduleJob, update obj_job(%d)", jobID64)
|
||||||
logOnError(err, s)
|
logOnError(err, s)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
Loading…
Reference in New Issue
Block a user