clarify comment

Signed-off-by: Julie Vogelman <[email protected]>
argoproj · Feb 2, 2022 · fe01a04 · fe01a04
1 parent f7d9acd
commit fe01a04
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/eventbus/driver/nats.go b/eventbus/driver/nats.go
@@ -258,9 +258,7 @@ func (n *natsStreaming) processEventSourceMsg(m *stan.Msg, msgHolder *eventSourc
 		return
 	}
 
-	// Clean up old messages before starting a new round
-
-	// ACK all the old messages after conditions are met
+	// Acknowledge any old messages that occurred either before the last reset
 	if m.Timestamp/1e9 <= msgHolder.getLastResetTime() {
 		log.Debugf("About to reset and ack dependency=%s due to message time occurred before reset, m.Timestamp=%d, msgHolder.getLastResetTime()=%d",
 			depName, m.Timestamp, msgHolder.getLastResetTime())