Mercurial > gemma

changeset 1751:c3a6aaf926c3

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
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)
 			}