From bf98f15dcf0afcdc64efca57dbc66ee28099fc27 Mon Sep 17 00:00:00 2001 From: Aravind Shankar Date: Mon, 6 Jan 2020 15:21:00 +0530 Subject: [PATCH] cli(fix): execute down migration in the correct order (#3625) --- cli/migrate/migrate.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/cli/migrate/migrate.go b/cli/migrate/migrate.go index 462cda8f..94be7800 100644 --- a/cli/migrate/migrate.go +++ b/cli/migrate/migrate.go @@ -803,7 +803,7 @@ func (m *Migrate) read(version uint64, direction string, ret chan<- interface{}) prev, err := m.sourceDrv.Prev(version) if os.IsNotExist(err) { // apply nil migration - migr, err := m.newMigration(version, -1) + migr, err := m.metanewMigration(version, -1) if err != nil { ret <- err return @@ -811,7 +811,7 @@ func (m *Migrate) read(version uint64, direction string, ret chan<- interface{}) ret <- migr go migr.Buffer() - migr, err = m.metanewMigration(version, -1) + migr, err = m.newMigration(version, -1) if err != nil { ret <- err return @@ -824,7 +824,7 @@ func (m *Migrate) read(version uint64, direction string, ret chan<- interface{}) return } - migr, err := m.newMigration(version, int64(prev)) + migr, err := m.metanewMigration(version, int64(prev)) if err != nil { ret <- err return @@ -833,7 +833,7 @@ func (m *Migrate) read(version uint64, direction string, ret chan<- interface{}) ret <- migr go migr.Buffer() - migr, err = m.metanewMigration(version, int64(prev)) + migr, err = m.newMigration(version, int64(prev)) if err != nil { ret <- err return