From 066d45690fdbf90e2b3da4289e106b84e679b668 Mon Sep 17 00:00:00 2001 From: shoopea Date: Thu, 29 Aug 2019 18:44:09 +0800 Subject: [PATCH] test timeout --- job.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/job.go b/job.go index c900735..ecc7f83 100644 --- a/job.go +++ b/job.go @@ -38,16 +38,16 @@ func createJob(jobTypeID int32, priority int32, userID64 int64, trigger int64, s } stmt, err = db.Prepare(`INSERT INTO obj_job (obj_id, priority, user_id, trigger_id, seq_nr, schedule, is_done, in_work, inserted, timeout, pulled, started, ended, payload) - VALUES (?, ?, ?, ?, NULL, ?, 0, 0, ?, ?, NULL, NULL, NULL, ?);`) + VALUES (?, ?, ?, ?, NULL, ?, 0, 0, ?, ?, NULL, NULL, NULL, ?);`) logOnError(err, "createJob : prepare insert obj_job") if err != nil { return 0, err } defer stmt.Close() - log.Printf("createJob : timeout : %s\n.", time.Unix(maxUnixTimestamp, 0).UTC().Format(time.RFC3339)) + log.Printf("createJob : timeout : %s.\n", time.Unix(maxUnixTimestamp, 0).UTC().Format(time.RFC3339)) - _, err = stmt.Exec(objId, priority, userID64, trigger, schedule.UTC(), time.Now().UTC(), time.Unix(maxUnixTimestamp, 0), payload) + _, err = stmt.Exec(objId, priority, userID64, trigger, schedule.UTC(), time.Now().UTC(), time.Now().UTC(), payload) logOnError(err, "createJob : insert obj_job") if err != nil { return 0, err