diff --git a/cdprocessor.go b/cdprocessor.go index c948692..0e9f520 100644 --- a/cdprocessor.go +++ b/cdprocessor.go @@ -388,7 +388,7 @@ func (s *Server) runLink(ctx context.Context) error { for _, rip := range s.rips { err := s.makeLinks(ctx, rip.Id, false) st := status.Convert(err) - if st.Code() != codes.ResourceExhausted || err != nil { + if st.Code() != codes.ResourceExhausted && err != nil { return err } s.count++