File tree Expand file tree Collapse file tree 2 files changed +4
-0
lines changed
Expand file tree Collapse file tree 2 files changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -265,6 +265,7 @@ impl Node {
265265 self . task_manager
266266 . task_spawner ( )
267267 . build_task ( )
268+ . graceful_shutdown ( )
268269 . name ( "Pipeline" )
269270 . spawn ( self . pipeline . into_future ( ) ) ;
270271
Original file line number Diff line number Diff line change @@ -39,6 +39,7 @@ use katana_metrics::Metrics;
3939use parking_lot:: Mutex ;
4040
4141/// Metrics for the sync pipeline.
42+ #[ allow( missing_debug_implementations) ]
4243#[ derive( Clone ) ]
4344pub struct PipelineMetrics {
4445 inner : Arc < PipelineMetricsInner > ,
@@ -91,6 +92,7 @@ impl Default for PipelineMetrics {
9192 }
9293}
9394
95+ #[ allow( missing_debug_implementations) ]
9496struct PipelineMetricsInner {
9597 /// Overall pipeline metrics
9698 pipeline : PipelineOverallMetrics ,
@@ -150,6 +152,7 @@ impl StageMetrics {
150152}
151153
152154/// Guard that records the execution duration when dropped.
155+ #[ allow( missing_debug_implementations) ]
153156pub struct StageExecutionGuard {
154157 metrics : StageMetrics ,
155158 started_at : Instant ,
You can’t perform that action at this time.
0 commit comments