diff options
| -rw-r--r-- | cmd/cli/reset.go | 3 | ||||
| -rw-r--r-- | cmd/cli/root.go | 2 | ||||
| -rw-r--r-- | cmd/cli/workers.go | 2 |
3 files changed, 4 insertions, 3 deletions
diff --git a/cmd/cli/reset.go b/cmd/cli/reset.go index a5055a53..40428fe3 100644 --- a/cmd/cli/reset.go +++ b/cmd/cli/reset.go @@ -71,7 +71,8 @@ func resetHandler(_ *cobra.Command, args []string) error { defer bar.Increment() var done bool - err = client.Call(Reset, service, &done) + cl := client.Go(Reset, service, &done, nil) + <-cl.Done if err != nil { result <- errors.E(op, err) return diff --git a/cmd/cli/root.go b/cmd/cli/root.go index 6f73aecf..d29e5d3b 100644 --- a/cmd/cli/root.go +++ b/cmd/cli/root.go @@ -78,7 +78,7 @@ func init() { // if debug mode is on - run debug server if Debug { - runDebugServer() + go runDebugServer() } }) } diff --git a/cmd/cli/workers.go b/cmd/cli/workers.go index 09642a58..defcb849 100644 --- a/cmd/cli/workers.go +++ b/cmd/cli/workers.go @@ -84,11 +84,11 @@ func workersHandler(_ *cobra.Command, args []string) error { return nil case <-tt.C: tm.MoveCursor(1, 1) + tm.Flush() err := showWorkers(plugins, client) if err != nil { return errors.E(op, err) } - tm.Flush() } } } |