tweak migration perf
This commit is contained in:
parent
2f3c912ad9
commit
53271729b6
@ -922,7 +922,12 @@ func UpgradeActorsV3(ctx context.Context, sm *StateManager, cache MigrationCache
|
|||||||
workerCount = 1
|
workerCount = 1
|
||||||
}
|
}
|
||||||
|
|
||||||
config := nv10.Config{MaxWorkers: uint(workerCount)}
|
config := nv10.Config{
|
||||||
|
MaxWorkers: uint(workerCount),
|
||||||
|
JobQueueSize: 1000,
|
||||||
|
ResultQueueSize: 100,
|
||||||
|
ProgressLogPeriod: 10 * time.Second,
|
||||||
|
}
|
||||||
newRoot, err := upgradeActorsV3Common(ctx, sm, cache, root, epoch, ts, config)
|
newRoot, err := upgradeActorsV3Common(ctx, sm, cache, root, epoch, ts, config)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return cid.Undef, xerrors.Errorf("migrating actors v3 state: %w", err)
|
return cid.Undef, xerrors.Errorf("migrating actors v3 state: %w", err)
|
||||||
|
Loading…
Reference in New Issue
Block a user