Mercurial > gemma
changeset 5110:4dc2e6dc6c7d queued-stage-done
Redirect logging of review job to original import log.
| author | Sascha L. Teichmann <sascha.teichmann@intevation.de> |
|---|---|
| date | Wed, 25 Mar 2020 15:33:11 +0100 |
| parents | c0ceec7e6f85 |
| children | 90b0a14dd58b |
| files | pkg/imports/queue.go |
| diffstat | 1 files changed, 14 insertions(+), 1 deletions(-) [+] |
line wrap: on
line diff
--- a/pkg/imports/queue.go Wed Mar 25 15:11:04 2020 +0100 +++ b/pkg/imports/queue.go Wed Mar 25 15:33:11 2020 +0100 @@ -92,6 +92,10 @@ AutoAccept() bool } + FeedbackCreator interface { + CreateFeedback(int64) Feedback + } + idJob struct { id int64 kind JobKind @@ -253,6 +257,10 @@ func (*reviewedJob) CleanUp() error { return nil } +func (r *reviewedJob) CreateFeedback(int64) Feedback { + return logFeedback(r.ID) +} + func (rj *reviewedJob) Do( ctx context.Context, importID int64, @@ -889,7 +897,12 @@ return } - feedback := logFeedback(idj.id) + var feedback Feedback + if fc, ok := job.(FeedbackCreator); ok { + feedback = fc.CreateFeedback(idj.id) + } else { + feedback = logFeedback(idj.id) + } feedback.Info("import #%d started", idj.id)