Update sector-storage with windowed scheduler

2020-07-18 00:38:02 +02:00
parent e02b40f04f
commit d266c665b0
3 changed files with 4 additions and 10 deletions
@@ -460,13 +460,7 @@ func SectorStorage(mctx helpers.MetricsCtx, lc fx.Lifecycle, ls stores.LocalStor
 	}

 	lc.Append(fx.Hook{
-		OnStop: func(_ context.Context) error {
-			if err := sst.Close(); err != nil {
-				log.Errorf("%+v", err)
-			}
-
-			return nil
-		},
+		OnStop: sst.Close,
 	})

 	return sst, nil