From 33bd15db3973432dfd603bd93be119988e883d2b Mon Sep 17 00:00:00 2001 From: Patrick Date: Thu, 9 May 2024 10:08:38 -0400 Subject: [PATCH] changed spammy error log to debug (#13153) (cherry picked from commit 3502176718f8cfa542ff5bb9f46b60c845c21c57) --- core/services/pipeline/runner.go | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/core/services/pipeline/runner.go b/core/services/pipeline/runner.go index 2de27b3d008..2fbce7ed00d 100644 --- a/core/services/pipeline/runner.go +++ b/core/services/pipeline/runner.go @@ -457,18 +457,14 @@ func (r *runner) run(ctx context.Context, pipeline *Pipeline, run *Run, vars Var "run.Inputs", run.Inputs, ) } - if run.HasFatalErrors() { - l = l.With("run.FatalErrors", run.FatalErrors) - } - if run.HasErrors() { - l = l.With("run.AllErrors", run.AllErrors) - } l = l.With("run.State", run.State, "fatal", run.HasFatalErrors(), "runTime", runTime) if run.HasFatalErrors() { // This will also log at error level in OCR if it fails Observe so the // level is appropriate - l.Errorw("Completed pipeline run with fatal errors") + l = l.With("run.FatalErrors", run.FatalErrors) + l.Debugw("Completed pipeline run with fatal errors") } else if run.HasErrors() { + l = l.With("run.AllErrors", run.AllErrors) l.Debugw("Completed pipeline run with errors") } else { l.Debugw("Completed pipeline run successfully")