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}
 
 }