Update if statement format

uber · Mar 14, 2020 · 319fce6 · 319fce6
1 parent a37d388
commit 319fce6
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/service/history/historyEngine.go b/service/history/historyEngine.go
@@ -2904,8 +2904,13 @@ func (e *historyEngineImpl) ReapplyEvents(
 				return nil, err
 			}
 			for _, event := range reapplyEvents {
+				if event.GetVersion() == lastWriteVersion {
+					// The reapply is from the same cluster. Ignoring.
+					continue
+				}
 				dedupResource := definition.NewEventReappliedID(runID, event.GetEventId(), event.GetVersion())
-				if event.GetVersion() == lastWriteVersion || mutableState.IsResourceDuplicated(dedupResource) {
+				if mutableState.IsResourceDuplicated(dedupResource) {
+					// already apply the signal
 					continue
 				}
 				toReapplyEvents = append(toReapplyEvents, event)