X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/5185c0d7e1d9aa8ea4abe46e4bbc0927e52e9a66..b0cf100405e0dd7e4913194cd88b71ff74cf1773:/services/keepstore/keepstore.go?ds=sidebyside

diff --git a/services/keepstore/keepstore.go b/services/keepstore/keepstore.go
index 75b6c4014d..1e8c3d1e0f 100644
--- a/services/keepstore/keepstore.go
+++ b/services/keepstore/keepstore.go
@@ -13,6 +13,8 @@ import (
 	"strings"
 	"syscall"
 	"time"
+	"git.curoverse.com/arvados.git/sdk/go/arvadosclient"
+	"git.curoverse.com/arvados.git/sdk/go/keepclient"
 )
 
 // ======================
@@ -274,6 +276,20 @@ func main() {
 		log.Fatal(err)
 	}
 
+	// Initialize Pull queue and worker
+	arv, err := arvadosclient.MakeArvadosClient()
+	if err != nil {
+		log.Fatalf("Error setting up arvados client %s", err.Error())
+	}
+
+	keepClient, err := keepclient.MakeKeepClient(&arv)
+	if err != nil {
+		log.Fatalf("Error setting up keep client %s", err.Error())
+	}
+
+	pullq = NewWorkQueue()
+	go RunPullWorker(pullq, keepClient)
+
 	// Shut down the server gracefully (by closing the listener)
 	// if SIGTERM is received.
 	term := make(chan os.Signal, 1)