Skip to content

Commit 90ad7a0

Browse files
author
Andrew Mason
committed
Handle the rest of rows.Err cases
1 parent 61de098 commit 90ad7a0

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

go/logic/applier.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -371,6 +371,8 @@ func (this *Applier) ReadMigrationMinValues(uniqueKey *sql.UniqueKey) error {
371371
}
372372
}
373373
log.Infof("Migration min values: [%s]", this.migrationContext.MigrationRangeMinValues)
374+
375+
err = rows.Err()
374376
return err
375377
}
376378

@@ -392,6 +394,8 @@ func (this *Applier) ReadMigrationMaxValues(uniqueKey *sql.UniqueKey) error {
392394
}
393395
}
394396
log.Infof("Migration max values: [%s]", this.migrationContext.MigrationRangeMaxValues)
397+
398+
err = rows.Err()
395399
return err
396400
}
397401

0 commit comments

Comments
 (0)