From 7b82b2c4bc9c0dc141e234dd4e90e93d78a4e032 Mon Sep 17 00:00:00 2001 From: Frrist Date: Wed, 1 Jun 2022 10:32:04 -0700 Subject: [PATCH] fix: pass workers to diff scheduler (#68) --- diff_parallel.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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,