File tree Expand file tree Collapse file tree 1 file changed +10
-1
lines changed
Expand file tree Collapse file tree 1 file changed +10
-1
lines changed Original file line number Diff line number Diff line change @@ -5732,10 +5732,16 @@ fn format_fleet_heartbeat_metric(
57325732 interval_seconds : u64 ,
57335733) -> String {
57345734 let activity = if sends_delta > 0 { "active" } else { "idle" } ;
5735+ let progress = if sends_delta > 0 {
5736+ "progressing"
5737+ } else {
5738+ "stalled"
5739+ } ;
57355740 format ! (
5736- "fleet-heartbeat state={} activity={} sends_total={} sends_delta={} interval ={}s" ,
5741+ "fleet-heartbeat state={} activity={} progress={} sends_total={} sends_delta={} window ={}s" ,
57375742 fleet_state_label( state) ,
57385743 activity,
5744+ progress,
57395745 sends_total,
57405746 sends_delta,
57415747 interval_seconds
@@ -11451,8 +11457,11 @@ runs:
1145111457 let idle = format_fleet_heartbeat_metric ( LoopState :: Running , 10 , 0 , 60 ) ;
1145211458 assert ! ( idle. contains( "state=running" ) ) ;
1145311459 assert ! ( idle. contains( "activity=idle" ) ) ;
11460+ assert ! ( idle. contains( "progress=stalled" ) ) ;
11461+ assert ! ( idle. contains( "window=60s" ) ) ;
1145411462 let active = format_fleet_heartbeat_metric ( LoopState :: Running , 12 , 2 , 60 ) ;
1145511463 assert ! ( active. contains( "activity=active" ) ) ;
11464+ assert ! ( active. contains( "progress=progressing" ) ) ;
1145611465 assert ! ( active. contains( "sends_total=12" ) ) ;
1145711466 assert ! ( active. contains( "sends_delta=2" ) ) ;
1145811467 let stopped = format_fleet_heartbeat_metric ( LoopState :: Stopped , 12 , 0 , 60 ) ;
You can’t perform that action at this time.
0 commit comments