lint

determined-ai · Jun 10, 2024 · 1732752 · 1732752
1 parent 51ce188
commit 1732752
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/master/pkg/stream/stream.go b/master/pkg/stream/stream.go
@@ -225,14 +225,13 @@ func (p *Publisher[T]) Broadcast(events []Event[T], idToSaturatedMsg map[int]*Up
 
 					if saturatedMsg, ok := idToSaturatedMsg[afterMsg.GetID()]; ok {
 						cachedSeq := saturatedMsg.SeqNum()
-						if cachedSeq == afterMsg.SeqNum() {
-							msg = sub.Streamer.PrepareFn(saturatedMsg)
-						} else {
+						if cachedSeq != afterMsg.SeqNum() {
 							if isInsert || isFallin {
 								userNotKnownIDs.Insert(afterMsg.GetID())
 							}
 							continue
 						}
+						msg = sub.Streamer.PrepareFn(saturatedMsg)
 					} else {
 						if isInsert || isFallin {
 							userNotKnownIDs.Insert(afterMsg.GetID())