From 7b3c63a8afa5bd305437f6913774c0e1e76eb569 Mon Sep 17 00:00:00 2001 From: chrislu Date: Thu, 5 Oct 2023 08:15:11 -0700 Subject: [PATCH] handle wrapped errors --- weed/s3api/s3api_circuit_breaker.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/weed/s3api/s3api_circuit_breaker.go b/weed/s3api/s3api_circuit_breaker.go index 9e197a2f9..6e14da0af 100644 --- a/weed/s3api/s3api_circuit_breaker.go +++ b/weed/s3api/s3api_circuit_breaker.go @@ -1,6 +1,7 @@ package s3api import ( + "errors" "fmt" "github.com/gorilla/mux" "github.com/seaweedfs/seaweedfs/weed/filer" @@ -30,7 +31,7 @@ func NewCircuitBreaker(option *S3ApiServerOption) *CircuitBreaker { err := pb.WithFilerClient(false, 0, option.Filer, option.GrpcDialOption, func(client filer_pb.SeaweedFilerClient) error { content, err := filer.ReadInsideFiler(client, s3_constants.CircuitBreakerConfigDir, s3_constants.CircuitBreakerConfigFile) - if err == filer_pb.ErrNotFound { + if errors.Is(err, filer_pb.ErrNotFound) { glog.Infof("s3 circuit breaker not configured") return nil }