Method runProgram

go/executor/executor.go:181–196

(program string, logStderr bool)

}

func (s *pythonExecutor) runProgram(program string, logStderr bool) error {
	cmd := sqlflowCmd(s.Cwd, s.Db.DriverName)
	cmd.Stdin = bytes.NewBufferString(program)

	errorLog, e := s.runCommand(cmd, nil, logStderr)
	if e != nil {
		// return the diagnostic message
		sub := rePyDiagnostics.FindStringSubmatch(errorLog)
		if len(sub) == 2 {
			return fmt.Errorf("%s", sub[1])
		}
		// if no diagnostic message, return the full stack trace
		return fmt.Errorf("failed: %v\n%sGenerated Code:%[2]s\n%s\n%[2]sOutput%[2]s\n%[4]v", e, "==========", program, errorLog)
	}
	return nil
}

func (s *pythonExecutor) runCommand(cmd *exec.Cmd, context map[string]string, logStderr bool) (string, error) {
	cw := &logChanWriter{wr: s.Writer}