fix log statement so it actually shows the reset time

Signed-off-by: Julie Vogelman <[email protected]>
argoproj · Feb 2, 2022 · 014e339 · 014e339
1 parent 3ac9f52
commit 014e339
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/eventbus/driver/nats.go b/eventbus/driver/nats.go
@@ -264,12 +264,13 @@ func (n *natsStreaming) processEventSourceMsg(m *stan.Msg, msgHolder *eventSourc
 		// ACK all the old messages after conditions are met
 		//if m.Timestamp <= msgHolder.latestGoodMsgTimestamp || m.Timestamp/1e9 <= msgHolder.getLastResetTime() {
 		if m.Timestamp/1e9 <= msgHolder.getLastResetTime() {
+			log.Debugf("About to reset and ack dependency=%s due to condition reset, m.Timestamp=%d, msgHolder.getLastResetTime()=%d",
+				depName, m.Timestamp, msgHolder.getLastResetTime())
+
 			if depName != "" {
 				msgHolder.reset(depName)
 			}
 			msgHolder.ackAndCache(m, event.ID())
-			log.Debugf("Reset and acked dependency=%s due to condition reset, m.Timestamp=%d, msgHolder.getLastResetTime()=%d",
-				depName, m.Timestamp, msgHolder.getLastResetTime())
 			return
 		}