mirror of https://github.com/milvus-io/milvus.git
Return the unavailable error to make the client's retry policy take effect (#17719)
Signed-off-by: SimFG <bang.fu@zilliz.com>pull/17755/head
parent
6cb00aa5bb
commit
3fadf4c5d7
internal/proxy
|
@ -20,6 +20,9 @@ import (
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
|
"google.golang.org/grpc/codes"
|
||||||
|
"google.golang.org/grpc/status"
|
||||||
|
|
||||||
"github.com/milvus-io/milvus/internal/proto/schemapb"
|
"github.com/milvus-io/milvus/internal/proto/schemapb"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -81,5 +84,5 @@ func ErrUnauthenticated() error {
|
||||||
}
|
}
|
||||||
|
|
||||||
func ErrProxyNotReady() error {
|
func ErrProxyNotReady() error {
|
||||||
return fmt.Errorf("internal: Milvus Proxy is not ready yet. please wait")
|
return status.Errorf(codes.Unavailable, "internal: Milvus Proxy is not ready yet. please wait")
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue