testtest
This commit is contained in:
parent
2cfa23e7d2
commit
393fdb289e
12
job.go
12
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")
|
||||
|
Loading…
Reference in New Issue
Block a user