Skip to content

Commit

Permalink
fix lint
Browse files Browse the repository at this point in the history
  • Loading branch information
RainbowDashy committed Jan 2, 2024
1 parent bf34efb commit 4340653
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions go/logic/migrator.go
Original file line number Diff line number Diff line change
Expand Up @@ -1157,7 +1157,7 @@ func (this *Migrator) initiateApplier() error {

// iterateChunks iterates the existing table rows, and generates a copy task of
// a chunk of rows onto the ghost table.
func (this *Migrator) iterateChunks() error {
func (this *Migrator) iterateChunks() {
terminateRowIteration := func(err error) error {
this.rowCopyComplete <- err
return this.migrationContext.Log.Errore(err)
Expand All @@ -1166,13 +1166,13 @@ func (this *Migrator) iterateChunks() error {
this.migrationContext.Log.Debugf("Noop operation; not really copying data")
terminateRowIteration(nil)
close(this.rowCopyComplete)
return nil
return
}
if this.migrationContext.MigrationRangeMinValues == nil {
this.migrationContext.Log.Debugf("No rows found in table. Rowcopy will be implicitly empty")
terminateRowIteration(nil)
close(this.rowCopyComplete)
return nil
return
}

var hasNoFurtherRangeFlag int64
Expand All @@ -1183,7 +1183,7 @@ func (this *Migrator) iterateChunks() error {
// Done
// There's another such check down the line
close(this.rowCopyComplete)
return nil
return
}
copyRowsFunc := func() error {
if atomic.LoadInt64(&this.rowCopyCompleteFlag) == 1 || atomic.LoadInt64(&hasNoFurtherRangeFlag) == 1 {
Expand Down

0 comments on commit 4340653

Please sign in to comment.