Mercurial > gemma
changeset 5101:1b0b13e70bc1 queued-stage-done
Proxy the original job creator directly and not only the dependencies.
author | Sascha L. Teichmann <sascha.teichmann@intevation.de> |
---|---|
date | Tue, 24 Mar 2020 16:47:49 +0100 |
parents | d3a24152b0be |
children | 8cc5b08ffc2b |
files | pkg/imports/queue.go |
diffstat | 1 files changed, 6 insertions(+), 6 deletions(-) [+] |
line wrap: on
line diff
--- a/pkg/imports/queue.go Tue Mar 24 16:42:10 2020 +0100 +++ b/pkg/imports/queue.go Tue Mar 24 16:47:49 2020 +0100 @@ -217,19 +217,19 @@ } type reviewedJobCreator struct { - dependencies [2][]string + jobCreator JobCreator } func (*reviewedJobCreator) AutoAccept() bool { return true } -func (r *reviewedJobCreator) Depends() [2][]string { - return r.dependencies +func (rjc *reviewedJobCreator) Depends() [2][]string { + return rjc.Depends() } -func (*reviewedJobCreator) Description() string { - return "review job creator" +func (rjc *reviewedJobCreator) Description() string { + return rjc.Description() + "#reviewed" } func (*reviewedJobCreator) StageDone(context.Context, *sql.Tx, int64, Feedback) error { @@ -322,7 +322,7 @@ q.creatorsMu.Lock() defer q.creatorsMu.Unlock() q.creators[kind] = jc - q.creators[kind+"#review"] = &reviewedJobCreator{dependencies: jc.Depends()} + q.creators[kind+"#review"] = &reviewedJobCreator{jobCreator: jc} }