Handle Provider closing in lifecycle

License: MIT
Signed-off-by: Łukasz Magiera <magik6k@gmail.com>

core/node/provider.go

@@ -30,6 +30,9 @@ func ProviderCtor(mctx MetricsCtx, lc fx.Lifecycle, queue *provider.Queue, rt ro
 			p.Run()
 			return nil
 		},
+		OnStop: func(ctx context.Context) error {
+			return p.Close()
+		},
 	})
 
 	return p