X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/a986c70c083ed53f9b2d0d112853d1a1155eedea..601764a10575232ada34a7c0dc5ec61195094e7f:/services/keepstore/handlers.go diff --git a/services/keepstore/handlers.go b/services/keepstore/handlers.go index e079b96784..2a1bbc972f 100644 --- a/services/keepstore/handlers.go +++ b/services/keepstore/handlers.go @@ -20,11 +20,10 @@ import ( "sync" "time" - "github.com/gorilla/mux" - "git.curoverse.com/arvados.git/sdk/go/arvados" "git.curoverse.com/arvados.git/sdk/go/health" "git.curoverse.com/arvados.git/sdk/go/httpserver" + "github.com/gorilla/mux" ) type router struct { @@ -669,6 +668,11 @@ func GetBlock(ctx context.Context, hash string, buf []byte, resp http.ResponseWr if !os.IsNotExist(err) { log.Printf("%s: Get(%s): %s", vol, hash, err) } + // If some volume returns a transient error, return it to the caller + // instead of "Not found" so it can retry. + if err == VolumeBusyError { + errorToCaller = err.(*KeepError) + } continue } // Check the file checksum.