# HG changeset patch # User Sascha L. Teichmann # Date 1585064869 -3600 # Node ID 1b0b13e70bc1266d013d29f09b721426d3450bc4 # Parent d3a24152b0bef6a2c6c3221b4dfaff247d444668 Proxy the original job creator directly and not only the dependencies. diff -r d3a24152b0be -r 1b0b13e70bc1 pkg/imports/queue.go --- 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} }