diff --git a/pkg/neg/syncers/transaction.go b/pkg/neg/syncers/transaction.go index 6f83cd3a99..c47d2115a2 100644 --- a/pkg/neg/syncers/transaction.go +++ b/pkg/neg/syncers/transaction.go @@ -163,6 +163,9 @@ func (s *transactionSyncer) syncInternal() error { s.logStats(currentMap, "after in-progress operations have completed, NEG endpoints") targetMap, endpointPodMap, err := s.endpointsCalculator.CalculateEndpoints(ep.(*apiv1.Endpoints), currentMap) + if err != nil { + return err + } s.logStats(targetMap, "desired NEG endpoints") // Calculate the endpoints to add and delete to transform the current state to desire state