[executor] Ensure correct log level for task stdout/stderr

Author: teo

executor/executable/basictask.go

@@ -59,8 +59,8 @@ func (t *BasicTask) makeTransitionFunc() transitioner.DoTransitionFunc {
 		var errStdout, errStderr error
 		var stdoutBuf, stderrBuf bytes.Buffer
 
-		stdoutLog := log.WithPrefix("task-stdout").WithField("task", t.ti.Name).Writer()
-		stderrLog := log.WithPrefix("task-stderr").WithField("task", t.ti.Name).Writer()
+		stdoutLog := log.WithPrefix("task-stdout").WithField("task", t.ti.Name).WriterLevel(logrus.DebugLevel)
+		stderrLog := log.WithPrefix("task-stderr").WithField("task", t.ti.Name).WriterLevel(logrus.ErrorLevel)
 
 		// Each of these multiwriters will push incoming lines to a buffer as well as the logger
 		stdout := io.MultiWriter(stdoutLog, &stdoutBuf)

executor/executable/controllabletask.go

@@ -80,7 +80,7 @@ func (t *ControllableTask) Launch() error {
 		_, errStdout = io.Copy(log.WithPrefix("task-stdout").WithField("task", t.ti.Name).WriterLevel(logrus.DebugLevel), stdoutIn)
 	}()
 	go func() {
-		_, errStderr = io.Copy(log.WithPrefix("task-stderr").WithField("task", t.ti.Name).WriterLevel(logrus.DebugLevel), stderrIn)
+		_, errStderr = io.Copy(log.WithPrefix("task-stderr").WithField("task", t.ti.Name).WriterLevel(logrus.ErrorLevel), stderrIn)
 	}()
 
 	log.WithFields(logrus.Fields{