Consolidate no-op states

This commit is contained in:
Tim Vaillancourt 2022-07-07 17:40:01 +02:00
parent 246800e053
commit 54db4174b3

View File

@ -220,7 +220,7 @@ func (this *Migrator) onChangelogStateEvent(dmlEvent *binlog.BinlogDMLEvent) (er
changelogState := ReadChangelogState(changelogStateString)
this.migrationContext.Log.Infof("Intercepted changelog state %s", changelogState)
switch changelogState {
case Migrated:
case Migrated, ReadMigrationRangeValues:
// no-op event
case GhostTableMigrated:
{
@ -241,8 +241,6 @@ func (this *Migrator) onChangelogStateEvent(dmlEvent *binlog.BinlogDMLEvent) (er
this.applyEventsQueue <- newApplyEventStructByFunc(&applyEventFunc)
}()
}
case ReadMigrationRangeValues:
// no-op event
default:
{
return fmt.Errorf("Unknown changelog state: %+v", changelogState)