diff --git a/pkg/kubectl/cmd/rollout/rollout_status.go b/pkg/kubectl/cmd/rollout/rollout_status.go
index 86b9aeb5a5a..1d47e82a7d0 100644
--- a/pkg/kubectl/cmd/rollout/rollout_status.go
+++ b/pkg/kubectl/cmd/rollout/rollout_status.go
@@ -127,7 +127,7 @@ func RunStatus(f *cmdutil.Factory, cmd *cobra.Command, out io.Writer, args []str
 
 	// if the rollout isn't done yet, keep watching deployment status
 	intr := interrupt.New(nil, w.Stop)
-	intr.Run(func() error {
+	return intr.Run(func() error {
 		_, err := watch.Until(0, w, func(e watch.Event) (bool, error) {
 			// print deployment's status
 			status, done, err := statusViewer.Status(cmdNamespace, info.Name)
@@ -143,5 +143,4 @@ func RunStatus(f *cmdutil.Factory, cmd *cobra.Command, out io.Writer, args []str
 		})
 		return err
 	})
-	return nil
 }
diff --git a/pkg/kubectl/cmd/run.go b/pkg/kubectl/cmd/run.go
index 24d8f88c8b5..c6e0d3e7e64 100644
--- a/pkg/kubectl/cmd/run.go
+++ b/pkg/kubectl/cmd/run.go
@@ -412,7 +412,7 @@ func waitForPod(podClient coreclient.PodsGetter, ns, name string, exitCondition
 
 	intr := interrupt.New(nil, w.Stop)
 	var result *api.Pod
-	intr.Run(func() error {
+	err = intr.Run(func() error {
 		ev, err := watch.Until(0, w, func(ev watch.Event) (bool, error) {
 			c, err := exitCondition(ev)
 			if c == false && err == nil {