Skip to content

Commit a7bd98d

Browse files
miltalexteo
authored andcommitted
[coconut] Keep stream open after Environment error
1 parent 55d20f1 commit a7bd98d

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

coconut/control/control.go

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -303,15 +303,15 @@ func CreateEnvironment(cxt context.Context, rpc *coconut.RpcClient, cmd *cobra.C
303303
return nil
304304
}
305305
fmt.Printf("\nEnvironment with id %s failed with error: %s\n", evt.EnvironmentId, evt.Error)
306-
return nil
307-
}
308-
tmpl, err := template.New("envEvents").Parse("Enviroment {{.EnvironmentId}} {{if .Message}}{{.Message}} {{end}}{{if .State}}changed state to {{.State}}{{end}}{{if .CurrentRunNumber}} with run number {{.CurrentRunNumber}}{{end}}\n")
309-
if err != nil {
310-
return err
311-
}
312-
err = tmpl.Execute(os.Stdout, evt)
313-
if err != nil {
314-
return err
306+
} else {
307+
tmpl, err := template.New("envEvents").Parse("Enviroment {{.EnvironmentId}} {{if .Message}}{{.Message}} {{end}}{{if .State}}changed state to {{.State}}{{end}}{{if .CurrentRunNumber}} with run number {{.CurrentRunNumber}}{{end}}\n")
308+
if err != nil {
309+
return err
310+
}
311+
err = tmpl.Execute(os.Stdout, evt)
312+
if err != nil {
313+
return err
314+
}
315315
}
316316
}
317317
if viper.GetBool("verbose") {

0 commit comments

Comments
 (0)