Fix: gracefully abort thread using sdk

Signed-off-by: Daishan Peng <daishan@acorn.io>

Author: StrongMonkey

go.mod

@@ -5,6 +5,8 @@ go 1.24.0
 replace (
 	github.com/obot-platform/obot/apiclient => ./apiclient
 	github.com/obot-platform/obot/logger => ./logger
+
+	github.com/gptscript-ai/gptscript => ../gptscript
 )
 
 require (

pkg/invoke/invoker.go

@@ -973,7 +973,7 @@ func (i *Invoker) stream(ctx context.Context, c kclient.WithWatch, thread *v1.Th
 	go timeoutAfter(runCtx, cancelRun, timeout)
 	if !isEphemeral(run) {
 		// Don't watch thread abort for ephemeral runs
-		go watchThreadAbort(runCtx, c, thread, cancelRun)
+		go i.watchThreadAbort(runCtx, c, thread, cancelRun, runResp)
 	}
 
 	var (
@@ -1070,10 +1070,13 @@ func (i *Invoker) stream(ctx context.Context, c kclient.WithWatch, thread *v1.Th
 	}
 }
 
-func watchThreadAbort(ctx context.Context, c kclient.WithWatch, thread *v1.Thread, cancel context.CancelCauseFunc) {
+func (i *Invoker) watchThreadAbort(ctx context.Context, c kclient.WithWatch, thread *v1.Thread, cancel context.CancelCauseFunc, run *gptscript.Run) {
 	_, _ = wait.For(ctx, c, thread, func(thread *v1.Thread) (bool, error) {
 		if thread.Spec.Abort {
-			cancel(fmt.Errorf("thread was aborted, cancelling run"))
+			if err := i.gptClient.AbortRun(ctx, run); err != nil {
+				return false, err
+			}
+			go timeoutAfter(ctx, cancel, 30*time.Second)
 			return true, nil
 		}
 		return false, nil