X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/d6e0bfffc0e79ef129d89ae220dcbebb6dc474a7..24223057a8dd3a03f1c6457287cb12167c6b67ee:/lib/controller/fed_collections.go diff --git a/lib/controller/fed_collections.go b/lib/controller/fed_collections.go index 07daf2f90e..c33f5b2894 100644 --- a/lib/controller/fed_collections.go +++ b/lib/controller/fed_collections.go @@ -17,9 +17,9 @@ import ( "strings" "sync" - "git.curoverse.com/arvados.git/sdk/go/arvados" - "git.curoverse.com/arvados.git/sdk/go/httpserver" - "git.curoverse.com/arvados.git/sdk/go/keepclient" + "git.arvados.org/arvados.git/sdk/go/arvados" + "git.arvados.org/arvados.git/sdk/go/httpserver" + "git.arvados.org/arvados.git/sdk/go/keepclient" ) func rewriteSignatures(clusterID string, expectHash string, @@ -232,6 +232,10 @@ func fetchRemoteCollectionByPDH( // No need to query local cluster again continue } + if remoteID == "*" { + // This isn't a real remote cluster: it just sets defaults for unlisted remotes. + continue + } wg.Add(1) go func(remote string) { @@ -293,10 +297,8 @@ func fetchRemoteCollectionByPDH( var errors []string for len(errorChan) > 0 { err := <-errorChan - if httperr, ok := err.(HTTPError); ok { - if httperr.Code != http.StatusNotFound { - errorCode = http.StatusBadGateway - } + if httperr, ok := err.(HTTPError); !ok || httperr.Code != http.StatusNotFound { + errorCode = http.StatusBadGateway } errors = append(errors, err.Error()) }