feat: set migration config UpgradeEpoch for v13 actors upgrade
This commit is contained in:
parent
c970dace57
commit
5cb25affdd
@ -2174,6 +2174,7 @@ func PreUpgradeActorsV13(ctx context.Context, sm *stmgr.StateManager, cache stmg
|
|||||||
config := migration.Config{
|
config := migration.Config{
|
||||||
MaxWorkers: uint(workerCount),
|
MaxWorkers: uint(workerCount),
|
||||||
ProgressLogPeriod: time.Minute * 5,
|
ProgressLogPeriod: time.Minute * 5,
|
||||||
|
UpgradeEpoch: build.UpgradeDragonHeight,
|
||||||
}
|
}
|
||||||
|
|
||||||
_, err = upgradeActorsV13Common(ctx, sm, cache, lbRoot, epoch, lbts, config)
|
_, err = upgradeActorsV13Common(ctx, sm, cache, lbRoot, epoch, lbts, config)
|
||||||
@ -2192,6 +2193,7 @@ func UpgradeActorsV13(ctx context.Context, sm *stmgr.StateManager, cache stmgr.M
|
|||||||
JobQueueSize: 1000,
|
JobQueueSize: 1000,
|
||||||
ResultQueueSize: 100,
|
ResultQueueSize: 100,
|
||||||
ProgressLogPeriod: 10 * time.Second,
|
ProgressLogPeriod: 10 * time.Second,
|
||||||
|
UpgradeEpoch: build.UpgradeDragonHeight,
|
||||||
}
|
}
|
||||||
newRoot, err := upgradeActorsV13Common(ctx, sm, cache, root, epoch, ts, config)
|
newRoot, err := upgradeActorsV13Common(ctx, sm, cache, root, epoch, ts, config)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
Loading…
Reference in New Issue
Block a user