diff --git a/diff_parallel.go b/diff_parallel.go
index c1fdd81..56f562a 100644
--- 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,