diff --git a/job.go b/job.go
index a29afcf..3e01d08 100644
--- a/job.go
+++ b/job.go
@@ -595,10 +595,11 @@ func jobPillage(j Job) {
 	} else { //no /go in the last 30 sec so we go ahead, send one and reschedule to check again in 25sec
 		t, err := getObjSubTypeId(r.ObjID64)
 		logOnError(err, "jobPillage : getObjSubTypeId")
+		m, err := getObjMsg(r.ObjID64)
+		logOnError(err, "jobPillage : getObjMsg")
 		if t == cacheObjSubType[`msg_pillage_inc`] {
 			clientSendCWMsg(j.UserID64, "/go")
 		} else if t == cacheObjSubType[`msg_pillage_inc2`] {
-			m, err := getObjMsg(r.ObjID64)
 			if len(m.Callbacks) != 1 {
 				s := TGCommand{
 					Type:       commandSendMsg,