From fe227a03d6f0cdcffb38e61a3179085fe0640a59 Mon Sep 17 00:00:00 2001
From: yedf2 <120050102@qq.com>
Date: Fri, 14 Jan 2022 21:21:39 +0800
Subject: [PATCH] reset redis barrier data

---
 test/busi/startup.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/test/busi/startup.go b/test/busi/startup.go
index 0c6e329..2b40a5c 100644
--- a/test/busi/startup.go
+++ b/test/busi/startup.go
@@ -1,8 +1,10 @@
 package busi
 
 import (
+	"context"
 	"fmt"
 
+	"github.com/dtm-labs/dtm/dtmcli/dtmimp"
 	"github.com/dtm-labs/dtm/dtmutil"
 	"github.com/gin-gonic/gin"
 )
@@ -20,4 +22,6 @@ func PopulateDB(skipDrop bool) {
 	dtmutil.RunSQLScript(BusiConf, file, skipDrop)
 	file = fmt.Sprintf("%s/dtmcli.barrier.%s.sql", dtmutil.GetSQLDir(), BusiConf.Driver)
 	dtmutil.RunSQLScript(BusiConf, file, skipDrop)
+	_, err := RedisGet().FlushAll(context.Background()).Result() // redis barrier need clear
+	dtmimp.E2P(err)
 }