diff --git a/cmd/cc-backend/server.go b/cmd/cc-backend/server.go index b37d3450..c9ba1e9c 100644 --- a/cmd/cc-backend/server.go +++ b/cmd/cc-backend/server.go @@ -357,8 +357,8 @@ func (s *Server) Start(ctx context.Context) error { s.server = &http.Server{ ReadHeaderTimeout: readHeaderTimeout, WriteTimeout: writeTimeout, - Handler: s.router, - Addr: config.Keys.Addr, + Handler: s.router, + Addr: config.Keys.Addr, } // Start http or https server @@ -444,7 +444,7 @@ func (s *Server) Shutdown(ctx context.Context) { select { case <-done: - case <-time.After(10 * time.Second): + case <-time.After(60 * time.Second): cclog.Warn("Shutdown deadline exceeded, forcing exit") } } diff --git a/internal/tagger/classifyJob.go b/internal/tagger/classifyJob.go index 1bad61f1..81698337 100644 --- a/internal/tagger/classifyJob.go +++ b/internal/tagger/classifyJob.go @@ -363,7 +363,7 @@ func (t *JobClassTagger) Match(job *schema.Job) { for _, m := range ri.metrics { stats, ok := jobStats[m] if !ok { - cclog.Errorf("job classification: missing metric '%s' for rule %s on job %d", m, tag, job.JobID) + cclog.Debugf("job classification: missing metric '%s' for rule %s on job %d", m, tag, job.JobID) skipRule = true break } @@ -388,7 +388,7 @@ func (t *JobClassTagger) Match(job *schema.Job) { for _, r := range ri.requirements { ok, err := expr.Run(r, env) if err != nil { - cclog.Errorf("error running requirement for rule %s: %#v", tag, err) + cclog.Debugf("error running requirement for rule %s: %#v", tag, err) requirementsMet = false break } @@ -407,7 +407,7 @@ func (t *JobClassTagger) Match(job *schema.Job) { for _, v := range ri.variables { value, err := expr.Run(v.expr, env) if err != nil { - cclog.Errorf("error evaluating variable %s for rule %s: %#v", v.name, tag, err) + cclog.Debugf("error evaluating variable %s for rule %s: %#v", v.name, tag, err) varError = true break }