Mercurial > gemma
changeset 1751:c3a6aaf926c3
Import queue: Harmonized logging output.
author | Sascha L. Teichmann <sascha.teichmann@intevation.de> |
---|---|
date | Thu, 10 Jan 2019 15:15:31 +0100 |
parents | b28faf6fbf98 |
children | 64fec6db7efc |
files | pkg/imports/queue.go |
diffstat | 1 files changed, 5 insertions(+), 5 deletions(-) [+] |
line wrap: on
line diff
--- a/pkg/imports/queue.go Thu Jan 10 15:08:58 2019 +0100 +++ b/pkg/imports/queue.go Thu Jan 10 15:15:31 2019 +0100 @@ -475,7 +475,7 @@ // re-enqueue the jobs that are in state running. // They where in progess when the server went down. if err := reEnqueueRunning(); err != nil { - log.Printf("re-enqueuing failed: %v", err) + log.Printf("error: re-enqueuing failed: %v", err) } for { @@ -484,7 +484,7 @@ for { if idj, err = q.fetchJob(); err != nil && err != sql.ErrNoRows { - log.Printf("db error: %v\n", err) + log.Printf("error: db: %v\n", err) } if idj != nil { break @@ -495,7 +495,7 @@ } } - log.Printf("starting import #%d\n", idj.id) + log.Printf("info: starting import #%d\n", idj.id) jc := q.jobCreator(idj.kind) if jc == nil { @@ -577,9 +577,9 @@ state = "pending" } if err := updateStateSummary(ctx, idj.id, state, summary); err != nil { - log.Printf("setting state of job %d failed: %v\n", idj.id, err) + log.Printf("error: setting state of job %d failed: %v\n", idj.id, err) } - log.Printf("import #%d finished: %s\n", idj.id, state) + log.Printf("info: import #%d finished: %s\n", idj.id, state) if idj.sendEmail { go sendNotificationMail(idj.user, jc.Description(), state, idj.id) }