Merge pull request #19 from skyhackvip/bug/1

fix bug goroutine
skyhackvip · Feb 22, 2024 · 336ffbe · 336ffbe
2 parents 5e3bab4 + a3dd329
commit 336ffbe
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