fix deferred migration

filecoin-project · Jan 3, 2024 · 0439243 · 0439243
1 parent 575a3b6
commit 0439243
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/migration/runner.go b/migration/runner.go
@@ -2,6 +2,7 @@ package migration
 
 import (
 	"context"
+	"errors"
 	"sync"
 	"sync/atomic"
 	"time"
@@ -86,7 +87,7 @@ func RunMigration(ctx context.Context, cfg Config, cache MigrationCache, store c
 			for job := range jobCh {
 				result, err := job.run(ctx, store)
 				if err != nil {
-					if err == errMigrationDeferred {
+					if errors.Is(err, errMigrationDeferred) {
 						atomic.AddUint32(&doneCount, 1)
 						continue
 					}

diff --git a/migration/util.go b/migration/util.go
@@ -2,6 +2,7 @@ package migration
 
 import (
 	"context"
+	"errors"
 	"sync"
 	"time"
 
@@ -232,7 +233,7 @@ func (d DeferredMigrator) MigratedCodeCID() cid.Cid {
 	panic("this can't be called")
 }
 
-var errMigrationDeferred = xerrors.Errorf("migration deferred")
+var errMigrationDeferred = errors.New("migration deferred")
 
 func (d DeferredMigrator) MigrateState(ctx context.Context, store cbor.IpldStore, in ActorMigrationInput) (*ActorMigrationResult, error) {
 	d.ds.lk.Lock()