ClusterCockpit/cc-backend
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-backend synced 2024-12-25 04:49:05 +01:00
Code Issues Packages Releases Activity

Improve logging

Browse Source
This commit is contained in:
Jan Eitzinger 2023-05-12 15:10:12 +02:00
parent c6dceb1265
commit 7213e7bb43
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cmd/cc-backend/main.go
View File

@ -422,6 +422,8 @@ func main() {
s := gocron.NewScheduler(time.Local) s := gocron.NewScheduler(time.Local)
if config.Keys.StopJobsExceedingWalltime > 0 { if config.Keys.StopJobsExceedingWalltime > 0 {
log.Info("Register undead jobs service")
s.Every(1).Day().At("3:00").Do(func() { s.Every(1).Day().At("3:00").Do(func() {
err := jobRepo.StopJobsExceedingWalltimeBy(config.Keys.StopJobsExceedingWalltime) err := jobRepo.StopJobsExceedingWalltimeBy(config.Keys.StopJobsExceedingWalltime)
if err != nil { if err != nil {
@ -436,12 +438,16 @@ func main() {
Retention schema.Retention `json:"retention"` Retention schema.Retention `json:"retention"`
} }
cfg.Retention.IncludeDB = true
if err := json.Unmarshal(config.Keys.Archive, &cfg); err != nil { if err := json.Unmarshal(config.Keys.Archive, &cfg); err != nil {
log.Warn("Error while unmarshaling raw config json") log.Warn("Error while unmarshaling raw config json")
} }
switch cfg.Retention.Policy { switch cfg.Retention.Policy {
case "delete": case "delete":
log.Info("Register retention service")
s.Every(1).Day().At("4:00").Do(func() { s.Every(1).Day().At("4:00").Do(func() {
startTime := time.Now().Unix() - int64(cfg.Retention.Age*24*3600) startTime := time.Now().Unix() - int64(cfg.Retention.Age*24*3600)
jobs, err := jobRepo.FindJobsBefore(startTime) jobs, err := jobRepo.FindJobsBefore(startTime)
@ -467,6 +473,8 @@ func main() {
} }
if cfg.Compression > 0 { if cfg.Compression > 0 {
log.Info("Register compression service")
s.Every(1).Day().At("5:00").Do(func() { s.Every(1).Day().At("5:00").Do(func() {
startTime := time.Now().Unix() - int64(cfg.Compression*24*3600) startTime := time.Now().Unix() - int64(cfg.Compression*24*3600)
jobs, err := jobRepo.FindJobsBefore(startTime) jobs, err := jobRepo.FindJobsBefore(startTime)