diff --git a/server.go b/server.go index 93a546218..2b455085c 100644 --- a/server.go +++ b/server.go @@ -855,7 +855,10 @@ func (s *Server) receiveMessage(m Message) error { s.holder.recalculateCaches() case *LoadSchemaMessage: - s.holder.LoadSchema() + err := s.holder.LoadSchema() + if err != nil { + return errors.Wrapf(err, "handling load schema message: %v", obj) + } case *NodeStatus: s.handleRemoteStatus(obj)