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")