comment

Signed-off-by: Julie Vogelman <[email protected]>
argoproj · Feb 2, 2022 · d12c52b · d12c52b
1 parent 408f62d
commit d12c52b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/eventbus/driver/nats.go b/eventbus/driver/nats.go
@@ -418,6 +418,7 @@ func (mh *eventSourceMessageHolder) setLastResetTime(t int64) {
 	mh.lastResetTime = t
 }
 
+// failsafe condition: determine if we for some reason we haven't acknowledged all dependencies within 60 seconds of the lastResetTime
 func (mh *eventSourceMessageHolder) fullResetTimeout() bool {
 	return mh.getLastResetTime() != 0 && time.Now().Unix()-mh.getLastResetTime() > 60 && mh.fullResetOccurrenceTime < mh.lastResetTime
 }