File tree Expand file tree Collapse file tree 3 files changed +3
-3
lines changed Expand file tree Collapse file tree 3 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -584,7 +584,7 @@ func (this *MigrationContext) GetIteration() int64 {
584
584
return atomic .LoadInt64 (& this .Iteration )
585
585
}
586
586
587
- func (this * MigrationContext ) SetNextIterationRangeValues () {
587
+ func (this * MigrationContext ) SetNextIterationRangeMinValues () {
588
588
this .MigrationIterationRangeMinValues = this .MigrationIterationRangeMaxValues
589
589
if this .MigrationIterationRangeMinValues == nil {
590
590
this .MigrationIterationRangeMinValues = this .MigrationRangeMinValues
Original file line number Diff line number Diff line change @@ -562,7 +562,7 @@ func (suite *ApplierTestSuite) TestPanicOnWarningsInApplyIterationInsertQuerySuc
562
562
err = applier .ReadMigrationRangeValues ()
563
563
suite .Require ().NoError (err )
564
564
565
- migrationContext .SetNextIterationRangeValues ()
565
+ migrationContext .SetNextIterationRangeMinValues ()
566
566
hasFurtherRange , expectedRangeSize , err := applier .CalculateNextIterationRangeEndValues ()
567
567
suite .Require ().NoError (err )
568
568
suite .Require ().True (hasFurtherRange )
Original file line number Diff line number Diff line change @@ -1244,7 +1244,7 @@ func (this *Migrator) iterateChunks() error {
1244
1244
return nil
1245
1245
}
1246
1246
copyRowsFunc := func () error {
1247
- this .migrationContext .SetNextIterationRangeValues ()
1247
+ this .migrationContext .SetNextIterationRangeMinValues ()
1248
1248
// Copy task:
1249
1249
applyCopyRowsFunc := func () error {
1250
1250
if atomic .LoadInt64 (& this .rowCopyCompleteFlag ) == 1 || atomic .LoadInt64 (& hasNoFurtherRangeFlag ) == 1 {
You can’t perform that action at this time.
0 commit comments