Update test.go

coretrix · Jul 1, 2024 · 447f772 · 447f772
1 parent f7fef9b
commit 447f772
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/pkg/test/test.go b/pkg/test/test.go
@@ -276,7 +276,12 @@ func executeAlters(ormService *beeorm.Engine) {
 
 	if os.Getenv("PARALLEL_TESTS") == "" || os.Getenv("PARALLEL_TESTS") == "false" {
 		ormService.GetLocalCache().Clear()
-		ormService.GetRedis().FlushAll()
+
+		pools := service.DI().App().RedisPools
+		ormService.GetRedis(pools.Stream).FlushDB()
+		ormService.GetRedis(pools.Persistent).FlushDB()
+		ormService.GetRedis(pools.Cache).FlushDB()
+		ormService.GetRedis(pools.Search).FlushDB()
 	}
 
 	altersSearch := ormService.GetRedisSearchIndexAlters()