X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/8989c3ca9c63dc05975b2c02e56c2031246beb96..e6ccda1f6925da119589e93b54d22508cf979069:/services/keepstore/pull_worker.go diff --git a/services/keepstore/pull_worker.go b/services/keepstore/pull_worker.go index b9194fe6f6..348bfb4df0 100644 --- a/services/keepstore/pull_worker.go +++ b/services/keepstore/pull_worker.go @@ -59,7 +59,7 @@ func (h *handler) pullItemAndProcess(pullRequest PullRequest) error { signedLocator := SignLocator(h.Cluster, pullRequest.Locator, keepClient.Arvados.ApiToken, time.Now().Add(time.Minute)) - reader, contentLen, _, err := GetContent(signedLocator, keepClient) + reader, _, _, err := GetContent(signedLocator, keepClient) if err != nil { return err } @@ -73,7 +73,7 @@ func (h *handler) pullItemAndProcess(pullRequest PullRequest) error { return err } - if (readContent == nil) || (int64(len(readContent)) != contentLen) { + if readContent == nil { return fmt.Errorf("Content not found for: %s", signedLocator) }