diff --git a/fracmanager/fracmanager.go b/fracmanager/fracmanager.go index 5df309f69..7a8b5585e 100644 --- a/fracmanager/fracmanager.go +++ b/fracmanager/fracmanager.go @@ -299,4 +299,5 @@ func sealOnShutdown(active *frac.Active, provider *fractionProvider, minSealSize if _, err := provider.Seal(active); err != nil { logger.Error("error sealing on shutdown", zap.Error(err)) } + active.Release() } diff --git a/fracmanager/loader.go b/fracmanager/loader.go index a3273c0ce..2de97d2c4 100644 --- a/fracmanager/loader.go +++ b/fracmanager/loader.go @@ -90,6 +90,7 @@ func (l *Loader) replayAndSeal(ctx context.Context, actives []*frac.Active) (*fr if err != nil { return err } + a.Release() sealed[i] = s return nil