Implement gp tasks stop --force-success (#20067)

* Implement `gp tasks stop --force-success`

* Fix potential race

Author: filiptronicek

components/gitpod-cli/cmd/tasks-stop.go

@@ -18,7 +18,8 @@ import (
 )
 
 var stopTaskCmdOpts struct {
-	All bool
+	All          bool
+	ForceSuccess bool
 }
 
 // stopTaskCmd represents the stop task command
@@ -113,7 +114,7 @@ var stopTaskCmd = &cobra.Command{
 		}
 
 		for _, terminalAlias := range terminalAliases {
-			_, err = client.Terminal.Shutdown(ctx, &api.ShutdownTerminalRequest{Alias: terminalAlias})
+			_, err = client.Terminal.Shutdown(ctx, &api.ShutdownTerminalRequest{Alias: terminalAlias, ForceSuccess: stopTaskCmdOpts.ForceSuccess})
 			if err != nil {
 				return xerrors.Errorf("cannot stop task: %w", err)
 			}
@@ -126,4 +127,5 @@ func init() {
 	tasksCmd.AddCommand(stopTaskCmd)
 
 	stopTaskCmd.Flags().BoolVarP(&stopTaskCmdOpts.All, "all", "a", false, "stop all tasks")
+	stopTaskCmd.Flags().BoolVarP(&stopTaskCmdOpts.ForceSuccess, "force-success", "f", false, "force the task to exit with status code 0")
 }

components/supervisor-api/go/terminal.pb.go

@@ -88,6 +88,7 @@ message OpenTerminalResponse {
 
 message ShutdownTerminalRequest {
     string alias = 1;
+    bool force_success = 2;
 }
 message ShutdownTerminalResponse {}
 

components/supervisor-api/go/terminal.pb.gw.go

@@ -330,7 +330,11 @@ func (tm *tasksManager) Run(ctx context.Context, wg *sync.WaitGroup, successChan
 			taskLog.Info("task terminal has been closed. Waiting for watch() to finish...")
 			taskWatchWg.Wait()
 			taskLog.Info("watch() has finished, setting task state to closed")
-			if state != nil {
+
+			if term.ForceSuccess {
+				// Simulate state.Success()
+				t.successChan <- taskSuccessful
+			} else if state != nil {
 				if state.Success() {
 					t.successChan <- taskSuccessful
 				} else {

components/supervisor-api/java/src/main/java/io/gitpod/supervisor/api/TerminalOuterClass.java

@@ -133,7 +133,7 @@ func (srv *MuxTerminalService) OpenWithOptions(ctx context.Context, req *api.Ope
 
 // Close closes a terminal for the given alias.
 func (srv *MuxTerminalService) Shutdown(ctx context.Context, req *api.ShutdownTerminalRequest) (*api.ShutdownTerminalResponse, error) {
-	err := srv.Mux.CloseTerminal(ctx, req.Alias)
+	err := srv.Mux.CloseTerminal(ctx, req.Alias, req.ForceSuccess)
 	if err == ErrNotFound {
 		return nil, status.Error(codes.NotFound, err.Error())
 	}