X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/224f384d411bb1b4cccc7165c55bb64fd5c695ad..3860042ac5783cddd368d8997991b0d1f8e9a111:/services/keepstore/pull_worker.go diff --git a/services/keepstore/pull_worker.go b/services/keepstore/pull_worker.go index d53d1060e7..3c6278d478 100644 --- a/services/keepstore/pull_worker.go +++ b/services/keepstore/pull_worker.go @@ -1,13 +1,15 @@ package main import ( + "context" "crypto/rand" "fmt" "git.curoverse.com/arvados.git/sdk/go/keepclient" "io" "io/ioutil" - "log" "time" + + log "github.com/Sirupsen/logrus" ) // RunPullWorker is used by Keepstore to initiate pull worker channel goroutine. @@ -94,6 +96,6 @@ func GenerateRandomAPIToken() string { // Put block var PutContent = func(content []byte, locator string) (err error) { - _, err = PutBlock(content, locator) + _, err = PutBlock(context.Background(), content, locator) return }