Use checkAbort

ggilder · ggilder · commit 8c0f8054dbb3 · 2026-03-10T15:55:08.000-07:00
diff --git a/go/logic/migrator.go b/go/logic/migrator.go
@@ -545,7 +545,7 @@ func (this *Migrator) Migrate() (err error) {
 	this.consumeRowCopyComplete()
 	this.migrationContext.Log.Infof("Row copy complete")
 	// Check if row copy was aborted due to error
-	if err := this.migrationContext.GetAbortError(); err != nil {
+	if err := this.checkAbort(); err != nil {
 		return err
 	}
 	if err := this.hooksExecutor.onRowCopyComplete(); err != nil {

Original file line number	Diff line number	Diff line change
`@@ -545,7 +545,7 @@ func (this *Migrator) Migrate() (err error) {`
`545`	`545`	`this.consumeRowCopyComplete()`
`546`	`546`	`this.migrationContext.Log.Infof("Row copy complete")`
`547`	`547`	`// Check if row copy was aborted due to error`
`548`		`- if err := this.migrationContext.GetAbortError(); err != nil {`
	`548`	`+ if err := this.checkAbort(); err != nil {`
`549`	`549`	`return err`
`550`	`550`	`}`
`551`	`551`	`if err := this.hooksExecutor.onRowCopyComplete(); err != nil {`