From 3ae4ae2acf318f723714da05644f97aa44aebfe3 Mon Sep 17 00:00:00 2001 From: Yaron Schneider Date: Tue, 15 Dec 2020 13:47:58 -0800 Subject: [PATCH] preserve daprd log output (#559) --- cmd/run.go | 27 ++------------------------- 1 file changed, 2 insertions(+), 25 deletions(-) diff --git a/cmd/run.go b/cmd/run.go index 75231af5..c72577a1 100644 --- a/cmd/run.go +++ b/cmd/run.go @@ -102,31 +102,8 @@ var RunCmd = &cobra.Command{ output.DaprHTTPPort, output.DaprGRPCPort)) - stdErrPipe, pipeErr := output.DaprCMD.StderrPipe() - if pipeErr != nil { - print.FailureStatusEvent(os.Stdout, fmt.Sprintf("Error creating stderr for Dapr: %s", err.Error())) - os.Exit(1) - } - - stdOutPipe, pipeErr := output.DaprCMD.StdoutPipe() - if pipeErr != nil { - print.FailureStatusEvent(os.Stdout, fmt.Sprintf("Error creating stdout for Dapr: %s", err.Error())) - os.Exit(1) - } - - errScanner := bufio.NewScanner(stdErrPipe) - outScanner := bufio.NewScanner(stdOutPipe) - go func() { - for errScanner.Scan() { - fmt.Println(print.Yellow(fmt.Sprintf("== DAPR == %s\n", errScanner.Text()))) - } - }() - - go func() { - for outScanner.Scan() { - fmt.Println(print.Yellow(fmt.Sprintf("== DAPR == %s\n", outScanner.Text()))) - } - }() + output.DaprCMD.Stdout = os.Stdout + output.DaprCMD.Stderr = os.Stderr err = output.DaprCMD.Start() if err != nil {