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")