From 662f0acc96f9be7224f898e85ebfb287adeb4e7a Mon Sep 17 00:00:00 2001 From: zhengb Date: Fri, 19 Dec 2025 13:18:54 +0800 Subject: [PATCH 1/2] fix(dialtesting): fix multi task retry --- dialtesting/multi.go | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/dialtesting/multi.go b/dialtesting/multi.go index ebdaf2db..8292f78b 100644 --- a/dialtesting/multi.go +++ b/dialtesting/multi.go @@ -164,12 +164,13 @@ func (t *MultiTask) runHTTPStep(step *MultiStep) (map[string]interface{}, error) for runCount < maxCount { httpTask := &HTTPTask{} task, err = NewTask(step.TaskString, httpTask) - if t.beforeRun != nil { - task.SetBeforeRun(t.beforeRun) - } if err != nil { return nil, fmt.Errorf("new task failed: %w", err) } + + if t.beforeRun != nil { + task.SetBeforeRun(t.beforeRun) + } task.SetOption(t.GetOption()) for _, v := range t.extractedVars { task.AddExtractedVar(&ConfigVar{ @@ -221,6 +222,10 @@ func (t *MultiTask) runHTTPStep(step *MultiStep) (map[string]interface{}, error) } task.Stop() + if err == nil { + break + } + runCount++ if runCount < maxCount { time.Sleep(interval) From 8a085bbf131227acc655860056dee4403766b393 Mon Sep 17 00:00:00 2001 From: zhengb Date: Fri, 19 Dec 2025 13:42:47 +0800 Subject: [PATCH 2/2] save --- dialtesting/multi.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dialtesting/multi.go b/dialtesting/multi.go index 8292f78b..ca3a3add 100644 --- a/dialtesting/multi.go +++ b/dialtesting/multi.go @@ -222,7 +222,7 @@ func (t *MultiTask) runHTTPStep(step *MultiStep) (map[string]interface{}, error) } task.Stop() - if err == nil { + if err == nil && result["status"] == "OK" { break }