fix: pass workers to diff scheduler (#68)

filecoin-project · Jun 1, 2022 · 7b82b2c · 7b82b2c
1 parent 1e3e6c6
commit 7b82b2c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/diff_parallel.go b/diff_parallel.go
@@ -49,7 +49,7 @@ func ParallelDiff(ctx context.Context, prevBs, curBs cbor.IpldStore, prev, cur c
 		return removeAll(ctx, prevCtx, prevAmt.node, 0)
 	}
 	out := make(chan *Change)
-	differ, ctx := newDiffScheduler(ctx, 1, &task{
+	differ, ctx := newDiffScheduler(ctx, workers, &task{
 		prevCtx: prevCtx,
 		curCtx:  curCtx,
 		prev:    prevAmt.node,