fix: resolve unit test failures

3 months ago · 6c2ecb2c79
2 changed files with 1 additions and 2 deletions
--- a/dtmsvr/trans_status.go
+++ b/dtmsvr/trans_status.go
@ -232,7 +232,7 @@ func (t *TransGlobal) execBranch(ctx context.Context, branch *TransBranch, branc
 		t.changeBranchStatus(branch, status, branchPos)
 	}
 	branchMetrics(t, branch, status == dtmcli.StatusSucceed)
-
+	// if time pass 1500ms and NextCronInterval is not default, then reset NextCronInterval
 	if err == nil && (time.Since(t.lastTouched)+NowForwardDuration >= 1500*time.Millisecond ||
 		t.NextCronInterval > conf.RetryInterval && t.NextCronInterval > t.RetryInterval) {
 		t.touchCronTime(cronReset, 0)
--- a/dtmsvr/trans_type_workflow.go
+++ b/dtmsvr/trans_type_workflow.go
@ -42,7 +42,6 @@ func (t *transWorkflowProcessor) ProcessOnce(ctx context.Context, branches []Tra
 		data = dtmgimp.MustProtoMarshal(&wd)
 	}
 	err := t.getURLResult(ctx, t.QueryPrepared, "00", cmc.Name, data)
-	// if time pass 1500ms and NextCronInterval is not default, then reset NextCronInterval
 	if err == dtmimp.ErrOngoing {
 		t.touchCronTime(cronKeep, 0)
 	} else if err != nil {