From 53271729b668846097bfb01635fef9a7eb0467ba Mon Sep 17 00:00:00 2001 From: Steven Allen Date: Thu, 28 Jan 2021 11:17:28 -0800 Subject: [PATCH] tweak migration perf --- chain/stmgr/forks.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/chain/stmgr/forks.go b/chain/stmgr/forks.go index 0e950a2b1..ca3b52d52 100644 --- a/chain/stmgr/forks.go +++ b/chain/stmgr/forks.go @@ -922,7 +922,12 @@ func UpgradeActorsV3(ctx context.Context, sm *StateManager, cache MigrationCache 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) if err != nil { return cid.Undef, xerrors.Errorf("migrating actors v3 state: %w", err)