parent
b2ff49be2e
commit
4a53f38d3a
|
@ -195,15 +195,15 @@ func (p *ResourceProvisioner) runScripts(conf *helper.SSHConfig, scripts []io.Re
|
||||||
}
|
}
|
||||||
cmd.Wait()
|
cmd.Wait()
|
||||||
|
|
||||||
rStdOut, wStdOut := io.Pipe()
|
stdOutReader, stdOutWriter := io.Pipe()
|
||||||
rStdErr, wStdErr := io.Pipe()
|
stdErrReader, stdErrWriter := io.Pipe()
|
||||||
go streamLogs(rStdOut, "stdout")
|
go streamLogs(stdOutReader, "stdout")
|
||||||
go streamLogs(rStdErr, "stderr")
|
go streamLogs(stdErrReader, "stderr")
|
||||||
|
|
||||||
cmd = &helper.RemoteCmd{
|
cmd = &helper.RemoteCmd{
|
||||||
Command: conf.ScriptPath,
|
Command: conf.ScriptPath,
|
||||||
Stdout: wPipe1,
|
Stdout: stdOutWriter,
|
||||||
Stderr: wPipe2,
|
Stderr: stdErrWriter,
|
||||||
}
|
}
|
||||||
if err := comm.Start(cmd); err != nil {
|
if err := comm.Start(cmd); err != nil {
|
||||||
return fmt.Errorf("Error starting script: %v", err)
|
return fmt.Errorf("Error starting script: %v", err)
|
||||||
|
|
Loading…
Reference in New Issue