diff --git a/job.go b/job.go index 7c0115a..42eb8e0 100644 --- a/job.go +++ b/job.go @@ -15,6 +15,8 @@ func jobRescan(j Job) { err = json.Unmarshal(j.Payload, &r) logOnError(err, "jobRescan : Unmarshal payload") + start := time.Now() + ids := getSQLListID64(r.Query) if len(ids) > 1 { @@ -25,7 +27,7 @@ func jobRescan(j Job) { JobID64: j.ID64, MsgID64: r.MsgID64, ChatID64: r.ChatID64, - Text: fmt.Sprintf("%d messages processed.", len(ids)), + Text: fmt.Sprintf("%d messages processed in %s.", len(ids), time.Since(start)), } b, _ := json.Marshal(p) err := createJob(objSubTypeJobSetJobDone, objJobPriorityRescanAllMsg, j.UserID64, time.Now(), b)