steve/databricks-cli
steve
/
databricks-cli
mirror of https://github.com/databricks/cli.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

proper printing

This commit is contained in:
Shreyas Goenka 2025-03-05 10:44:43 +01:00
parent 39d0b13c4f
commit 2212aa2597
No known key found for this signature in database
GPG Key ID: 92A07DF49CCB0622
3 changed files with 20 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
cmd/bundle/exec.go
View File

@ -112,37 +112,30 @@ Example usage:
var stdoutErr error
go func() {
reader := bufio.NewReader(stdout)
line, err := reader.ReadString('\n')
for err == nil {
_, err = fmt.Fprintf(cmd.OutOrStdout(), "%s\n", strings.TrimSpace(line))
defer wg.Done()
scanner := bufio.NewScanner(stdout)
for scanner.Scan() {
_, err = fmt.Fprintln(cmd.OutOrStdout(), scanner.Text())
if err != nil {
stdoutErr = err
break
}
line, err = reader.ReadString('\n')
}
wg.Done()
}()
var stderrErr error
go func() {
reader := bufio.NewReader(stderr)
// TODO CONTINUE: The formatting is messed u[] because of the new line business
// here.
// Fix that.
line, err := reader.ReadString('\n')
for err == nil {
_, err = fmt.Fprintf(cmd.ErrOrStderr(), "%s\n", strings.TrimSpace(line))
defer wg.Done()
scanner := bufio.NewScanner(stderr)
for scanner.Scan() {
_, err = fmt.Fprintln(cmd.ErrOrStderr(), scanner.Text())
if err != nil {
stderrErr = err
break
}
line, err = reader.ReadString('\n')
}
wg.Done()
}()
wg.Wait()