From bb8209bf7e238baedd0bdabe11d09518d2f44eee Mon Sep 17 00:00:00 2001 From: Christopher Baines Date: Mon, 13 May 2024 18:55:07 +0100 Subject: Update metrics after processing changes As this gets less confused if processing the changes fails and is repeated. --- nar-herder/recent-changes.scm | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) (limited to 'nar-herder') diff --git a/nar-herder/recent-changes.scm b/nar-herder/recent-changes.scm index 8ef5437..62bd604 100644 --- a/nar-herder/recent-changes.scm +++ b/nar-herder/recent-changes.scm @@ -151,9 +151,6 @@ (log-msg 'INFO "processing " (length unprocessed-recent-changes) " recent changes") - (metric-increment recent-changes-count-metric - #:by (length unprocessed-recent-changes)) - (for-each (lambda (change-details) (let ((change (assq-ref change-details 'change))) @@ -163,8 +160,10 @@ ((string=? change "removal") (process-removal-change change-details)) (else #f)))) - unprocessed-recent-changes)) + unprocessed-recent-changes) + (metric-increment recent-changes-count-metric + #:by (length unprocessed-recent-changes))) ;; Use the unprocessed recent changes here to carry ;; forward all processed changes to the next pass unprocessed-recent-changes)) -- cgit v1.2.3