diff --git a/job.go b/job.go index fe342ac..9875dd3 100644 --- a/job.go +++ b/job.go @@ -482,6 +482,14 @@ func jobPillage(j Job) { err = json.Unmarshal(j.Payload, &r) logOnError(err, "jobPillage : Unmarshal payload") + clt, _ := getLockedClient(j.UserID64, false) + clt.Mux.Unlock() + if !clt.Config.InterceptPillage { + err = setJobDone(j.ID64) + logOnError(err, "jobSetDone : setJobDone") + return + } + // check if we have a acknowledgment of go or a timeout within 3m30 of the PillageInc from the Job ids := getSQLListID64(`SELECT ox.id FROM obj ox