X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/3d5a1c29aad86476f2e789e1e54cabf8b4605aa2..f9e39b9d8ae46c3e1200e3eddc0bc68ea6ce0925:/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) }