diff --git a/core/exec/text.go b/core/exec/text.go index 9f20156..30b7da7 100644 --- a/core/exec/text.go +++ b/core/exec/text.go @@ -148,6 +148,7 @@ func RunTextCmd( } // Copy over commands STDOUT. + wg.Add(1) go func(client Client) { defer wg.Done() var err error @@ -161,9 +162,9 @@ func RunTextCmd( fmt.Fprintf(stderr, "%s", err) } }(t.client) - wg.Add(1) // Copy over tasks's STDERR. + wg.Add(1) go func(client Client) { defer wg.Done() var err error @@ -177,7 +178,6 @@ func RunTextCmd( fmt.Fprintf(stderr, "%s", err) } }(t.client) - wg.Add(1) wg.Wait()