exclude retries from lag accumulation

MetPX · Nov 29, 2024 · 7c5f470 · 7c5f470
1 parent 6056c95
commit 7c5f470
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/sarracenia/flowcb/log.py b/sarracenia/flowcb/log.py
@@ -170,9 +170,10 @@ def after_accept(self, worklist):
         for msg in worklist.incoming:
 
             lag = now - timestr2flt(msg['pubTime'])
-            self.lagTotal += lag
-            if lag > self.lagMax:
-                self.lagMax = lag
+            if not ( '_isRetry' in msg and msg['_isRetry']):
+               self.lagTotal += lag
+               if lag > self.lagMax:
+                   self.lagMax = lag
             if set(['after_accept']) & self.o.logEvents:
                 logger.info( f"accepted: (lag: {lag:.2f} ) {self._messageAcceptStr(msg)}" )