diff --git a/migrations/migrations.go b/migrations/migrations.go index bd2c4fa6a78327f2452f4c7575aafdf7019bc83e..70a62e33400a5ad1e68f15b6cc988c6c2d2eac14 100644 --- a/migrations/migrations.go +++ b/migrations/migrations.go @@ -30,7 +30,7 @@ import ( // if exists, err := db.(ethdb.NonTransactional).BucketExists(dbutils.SyncStageProgressOld1); err != nil { // return err // } else if !exists { -// return nil +// return OnLoadCommit(db, nil, true) // } // // if err := db.(ethdb.NonTransactional).ClearBuckets(dbutils.SyncStageProgress); err != nil { diff --git a/migrations/stages_to_use_named_keys.go b/migrations/stages_to_use_named_keys.go index 23d1866d4a43a1f832bbbc55dfcd00a60a6a8a3f..0e3cf52931f0eb6173f7e91ff236b72da6be4884 100644 --- a/migrations/stages_to_use_named_keys.go +++ b/migrations/stages_to_use_named_keys.go @@ -13,7 +13,7 @@ var stagesToUseNamedKeys = Migration{ if exists, err := db.(ethdb.NonTransactional).BucketExists(dbutils.SyncStageProgressOld1); err != nil { return err } else if !exists { - return nil + return OnLoadCommit(db, nil, true) } if err := db.(ethdb.NonTransactional).ClearBuckets(dbutils.SyncStageProgress); err != nil { @@ -57,7 +57,7 @@ var unwindStagesToUseNamedKeys = Migration{ if exists, err := db.(ethdb.NonTransactional).BucketExists(dbutils.SyncStageUnwindOld1); err != nil { return err } else if !exists { - return nil + return OnLoadCommit(db, nil, true) } if err := db.(ethdb.NonTransactional).ClearBuckets(dbutils.SyncStageUnwind); err != nil {