From 961d56747e3bdabf47c0e368358aceef5a52d4ff Mon Sep 17 00:00:00 2001 From: Uday Patil Date: Thu, 16 Nov 2023 14:15:59 -0500 Subject: [PATCH] add log --- tasks/scheduler.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tasks/scheduler.go b/tasks/scheduler.go index adb6b336a..82138ad01 100644 --- a/tasks/scheduler.go +++ b/tasks/scheduler.go @@ -98,8 +98,9 @@ func (s *scheduler) findConflicts(task *deliverTxTask) (bool, []int) { var conflicts []int uniq := make(map[int]struct{}) valid := true - for _, mv := range s.multiVersionStores { + for sk, mv := range s.multiVersionStores { ok, mvConflicts := mv.ValidateTransactionState(task.Index) + task.Ctx.Logger().Info("Validating MVS", "storeKey", sk.Name(), "ok", ok, "conflicts", mvConflicts) for _, c := range mvConflicts { if _, ok := uniq[c]; !ok { conflicts = append(conflicts, c) @@ -217,7 +218,6 @@ func (s *scheduler) shouldRerun(task *deliverTxTask) bool { // validated tasks can become unvalidated if an earlier re-run task now conflicts case statusExecuted, statusValidated: if valid, conflicts := s.findConflicts(task); !valid { - task.Ctx.Logger().Info("Task invalid", "index", task.Index, "incarnation", task.Incarnation, "conflicts", conflicts) s.invalidateTask(task) // if the conflicts are now validated, then rerun this task