diff options
| author | Christopher Baines <mail@cbaines.net> | 2024-05-13 18:55:07 +0100 |
|---|---|---|
| committer | Christopher Baines <mail@cbaines.net> | 2024-05-13 18:55:07 +0100 |
| commit | bb8209bf7e238baedd0bdabe11d09518d2f44eee (patch) | |
| tree | b931867d91af98900e0baec03d0d88927801ee49 /nar-herder | |
| parent | 89fa440848a2e126c4be8d8632cf438b3a4b31a2 (diff) | |
| download | nar-herder-master.tar nar-herder-master.tar.gz | |
As this gets less confused if processing the changes fails and is
repeated.
Diffstat (limited to 'nar-herder')
| -rw-r--r-- | nar-herder/recent-changes.scm | 7 |
1 files changed, 3 insertions, 4 deletions
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)) |