This commit is contained in:
Dominic Wong
2022-01-28 12:14:55 +00:00
parent cd215a8392
commit 6e7819626a

View File

@@ -42,8 +42,6 @@ func (m *migration) Do() error {
// max concurrency is 5
concurrencyChan := make(chan struct{}, 5)
var strg Migration
for _, t := range tables {
wg.Add(1)
@@ -54,6 +52,7 @@ func (m *migration) Do() error {
wg.Done()
<-concurrencyChan
}()
var strg Migration
if strings.HasSuffix(tableName, "_users") {
strg = userMgr.New(m.store, strings.TrimSuffix(tableName, "_users"))