fix throttling bug

This commit is contained in:
Aarsh Shah 2021-08-25 16:19:02 +05:30
parent 87fc8db5a9
commit 928ac2191b

View File

@ -748,7 +748,10 @@ func (sm *StorageMinerAPI) DagstoreInitializeAll(ctx context.Context, params api
}
err := sm.DagstoreInitializeShard(ctx, k)
if throttle != nil {
throttle <- struct{}{}
}
r.Event = "end"
if err == nil {