From 393fdb289ea524fed174da07d489c41c56eff78f Mon Sep 17 00:00:00 2001 From: shoopea Date: Tue, 11 Jun 2019 15:44:28 +0800 Subject: [PATCH] testtest --- job.go | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/job.go b/job.go index e818e8d..73e76ef 100644 --- a/job.go +++ b/job.go @@ -370,7 +370,17 @@ func jobMsgRefresh(j Job) { logOnError(err, "jobMsgRefresh : Unmarshal payload") m, err := getObjMsg(p.ObjID64) - logOnError(err, "jobMsgRefresh : getObjMsg") + + if err != nil && strings.Compare(err.Error(), `sql: no rows in result set`) == 0 { + err = setJobDone(j.ID64) + logOnError(err, "joMsgClient : setJobDone") + return + } else { + logOnError(err, "jobMsgRefresh : getObjMsg") + err = setJobDone(j.ID64) + logOnError(err, "joMsgClient : setJobDone") + return + } err = delObj(p.ObjID64) logOnError(err, "jobMsgRefresh : delObj")