gemma: pkg/imports/queue.go comparison

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

comparison

equal deleted inserted replaced

-:d3a24152b0be
+:1b0b13e70bc1
 func (ue UnchangedError) Error() string {
 	return string(ue)
 }
 type reviewedJobCreator struct {
-	dependencies [2][]string
+	jobCreator JobCreator
 }
 func (*reviewedJobCreator) AutoAccept() bool {
 	return true
 }
-func (r *reviewedJobCreator) Depends() [2][]string {
+func (rjc *reviewedJobCreator) Depends() [2][]string {
-	return r.dependencies
+	return rjc.Depends()
 }
-func (*reviewedJobCreator) Description() string {
+func (rjc *reviewedJobCreator) Description() string {
-	return "review job creator"
+	return rjc.Description() + "#reviewed"
 }
 func (*reviewedJobCreator) StageDone(context.Context, *sql.Tx, int64, Feedback) error {
 	return nil
 }
 func (q *importQueue) registerJobCreator(kind JobKind, jc JobCreator) {
 	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}
 }
 // FindJobCreator looks up a JobCreator in the global import queue.
 func FindJobCreator(kind JobKind) JobCreator {

Mercurial > gemma