fix bug goroutine

skyhackvip · Feb 22, 2024 · a3dd329 · a3dd329
1 parent 5e3bab4
commit a3dd329
Showing 1 changed file with 5 additions and 7 deletions.
diff --git a/core/flow.go b/core/flow.go
@@ -71,13 +71,11 @@ func (flow *DecisionFlow) GetStartNode() (*FlowNode, bool) {
 
 func (flow *DecisionFlow) Run(ctx *PipelineContext) (err error) {
 	//recover
-	go func() {
-		defer func() {
-			if err := recover(); err != nil {
-				err = err
-				log.Error(err)
-			}
-		}()
+	defer func() {
+		if r := recover(); r != nil {
+			err = fmt.Errorf("recovered from panic: %v", r)
+			log.Error(err)
+		}
 	}()
 
 	//find StartNode