X-Git-Url: https://jxself.org/git/?p=8sync.git;a=blobdiff_plain;f=8sync%2Factors.scm;fp=8sync%2Factors.scm;h=37f321bed89011f4e89b8bb6071d96ef3da9467c;hp=bf1093ab542d1101328bc83a9449ee49c35fcfde;hb=08fb307989f2696ddbd2ad535f55558c577b2fdb;hpb=1c7504b3ea4ead41410c660702eccf70b6556363 diff --git a/8sync/actors.scm b/8sync/actors.scm index bf1093a..37f321b 100644 --- a/8sync/actors.scm +++ b/8sync/actors.scm @@ -731,7 +731,7 @@ its '*cleanup* action handler." (let* ((queue (list->q initial-tasks)) (agenda (make-agenda #:pre-unwind-handler print-error-and-continue #:queue queue))) - (start-agenda agenda))) + (run-agenda agenda))) ;; Run cleanup (lambda () (when cleanup @@ -740,7 +740,7 @@ its '*cleanup* action handler." (define (run-hive-cleanup hive) (let ((queue (list->q (list (bootstrap-message hive (actor-id hive) '*cleanup-all*))))) - (start-agenda + (run-agenda (make-agenda #:queue queue)))) (define (bootstrap-message hive to-id action . message-body-args)