3761: Pass pullq to RunPullWorker

[arvados.git] / services / keepstore / pull_worker.go

diff --git a/services/keepstore/pull_worker.go b/services/keepstore/pull_worker.go
index dced531bf5fb08ac8bd808818ca8bf021128de31..db1d756ad8748ea0b365a296e2a0a162fed15747 100644 (file)
--- a/services/keepstore/pull_worker.go
+++ b/services/keepstore/pull_worker.go
@@ -22,7 +22,8 @@ var keepClient keepclient.KeepClient
                        Skip the rest of the servers if no errors
                Repeat
 */
-func RunPullWorker(nextItem <-chan interface{}, kc keepclient.KeepClient) {
+func RunPullWorker(pullq *WorkQueue, kc keepclient.KeepClient) {
+       nextItem := pullq.NextItem
        keepClient = kc
        for item := range nextItem {
                Pull(item.(PullRequest))