From 57474ac8c8c75cdbcac7e08eb38932e4c67f1d01 Mon Sep 17 00:00:00 2001 From: sophia Date: Mon, 20 Sep 2021 14:32:11 -0500 Subject: [PATCH] Periodically prune old jobs from bolt --- internal/server/singleprocess/state/state.go | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/internal/server/singleprocess/state/state.go b/internal/server/singleprocess/state/state.go index 7c8ab5193..183cb052a 100644 --- a/internal/server/singleprocess/state/state.go +++ b/internal/server/singleprocess/state/state.go @@ -151,8 +151,17 @@ func (s *State) Prune() error { s.log.Debug("Finished pruning data", "removed-jobs", jobs, ) - memTxn.Commit() + + // Prune jobs from bolt + dbJobs, err := s.jobsDBPruneOld(maximumJobsIndexed) + if err != nil { + return err + } + s.log.Debug("Finished pruning db data", + "removed-jobs", dbJobs, + ) + return nil }