diff --git a/internal/nodes/http_cache_task_manager.go b/internal/nodes/http_cache_task_manager.go index 8ee40f8..9260781 100644 --- a/internal/nodes/http_cache_task_manager.go +++ b/internal/nodes/http_cache_task_manager.go @@ -106,6 +106,10 @@ func (this *HTTPCacheTaskManager) Loop() error { resp, err := rpcClient.HTTPCacheTaskKeyRPC().FindDoingHTTPCacheTaskKeys(rpcClient.Context(), &pb.FindDoingHTTPCacheTaskKeysRequest{}) if err != nil { + // 忽略连接错误 + if rpc.IsConnError(err) { + return nil + } return err }