Periodically prune old jobs from bolt

2021-09-20 14:32:11 -05:00 · 2021-09-20 14:32:11 -05:00 · 57474ac8c8
commit 57474ac8c8
parent 2991810e0c
1 changed files with 10 additions and 1 deletions
--- 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
 }