X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/d9f2aaaa6b5762f448276ce96b6994245062a4c8..7692a12d05d54f0e209dcc2ff9ae9152560c7d52:/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 }