X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/3583e494ed815632bbaa2582fd0a49110a21123b..2d046e6afeb13988d1438a05301d60a5d399a371:/services/keepstore/pull_worker.go?ds=sidebyside 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) }