diff --git a/agent/rpc/peering/service.go b/agent/rpc/peering/service.go index 3956ba9f65..ae2c3974ae 100644 --- a/agent/rpc/peering/service.go +++ b/agent/rpc/peering/service.go @@ -408,7 +408,7 @@ func (s *Server) validatePeeringInPartition(remotePeerID, partition string) erro return fmt.Errorf("cannot read peering by ID: %w", err) } - if peering != nil && peering.GetPartition() == partition { + if peering != nil && acl.EqualPartitions(peering.GetPartition(), partition) { return fmt.Errorf("cannot create a peering within the same partition (ENT) or cluster (OSS)") }