aboutsummaryrefslogtreecommitdiff
path: root/nar-herder/server.scm
diff options
context:
space:
mode:
Diffstat (limited to 'nar-herder/server.scm')
-rw-r--r--nar-herder/server.scm14
1 files changed, 8 insertions, 6 deletions
diff --git a/nar-herder/server.scm b/nar-herder/server.scm
index d84424d..b4c0ad2 100644
--- a/nar-herder/server.scm
+++ b/nar-herder/server.scm
@@ -366,11 +366,8 @@
(when (and (not loop?)
maybe-trigger-creation-of-compressed-nars)
- (spawn-fiber
- (lambda ()
- (maybe-trigger-creation-of-compressed-nars
- (assq-ref narinfo 'id)))
- #:parallel? #t))
+ (maybe-trigger-creation-of-compressed-nars
+ (assq-ref narinfo 'id)))
(when loop?
(log-msg logger 'WARN
@@ -619,6 +616,9 @@
(make-gauge-metric metrics-registry "recent_changes_limit")))
(metric-set recent-changes-metric (assq-ref opts 'recent-changes-limit)))
+ (define maintenance-scheduler
+ (make-scheduler #:parallelism 1))
+
(let* ((database (setup-database (assq-ref opts 'database)
metrics-registry))
(canonical-storage (and=> (assq-ref opts 'storage)
@@ -669,7 +669,8 @@
enabled-cached-compressions
cached-compression-min-uses
#:cached-compression-workers
- (assq-ref opts 'cached-compression-workers)))))
+ (assq-ref opts 'cached-compression-workers)
+ #:scheduler scheduler))))
(if (string=? (assq-ref opts 'database-dump)
"disabled")
@@ -771,6 +772,7 @@
(log-msg 'DEBUG "finished maintenance setup")
(wait finished?))
+ #:scheduler maintenance-scheduler
#:hz 0
#:parallelism 1)))