修改Bug

pipeline/pipeline.go

@@ -27,17 +27,17 @@ func (p *Pipeline) Run(globalRunParams map[string]any, dynamicParams map[string]
 	token := NewRunToken()
 
 	go func() {
-		defer token.Done()
-
 		result, err := p.Flow.Run(&component.GlobalRunParams{
 			CustomRunParams: globalRunParams,
 		}, dynamicParams)
 		if err != nil {
 			token.Err = err
+			token.Done()
 			return
 		}
 
 		token.Result = result
+		token.Done()
 	}()
 
 	return token