diff --git a/pkg/icingadb/ha.go b/pkg/icingadb/ha.go index e6b05ba3..594a93bc 100644 --- a/pkg/icingadb/ha.go +++ b/pkg/icingadb/ha.go @@ -233,14 +233,15 @@ func (h *HA) realize(s *icingaredisv1.IcingaStatus, t *types.UnixMilli, shouldLo } } - cancel() - if err := tx.Commit(); err != nil { + cancel() return err } if takeover { h.signalTakeover() } + + cancel() break }