@@ -279,15 +279,13 @@ async def _periodically_report_progress(self) -> None:
279
279
while self .is_running :
280
280
requested_nodes = sum (
281
281
len (node_keys ) for _ , node_keys in self ._active_requests .values ())
282
- self .logger .info ("====== State sync progress ========" )
283
- self .logger .info ("Nodes processed: %d" , self ._total_processed_nodes )
284
- self .logger .info ("Nodes processed per second (average): %d" ,
285
- self ._total_processed_nodes / self ._timer .elapsed )
286
- self .logger .info ("Nodes committed to DB: %d" , self .scheduler .committed_nodes )
287
- self .logger .info ("Nodes requested but not received yet: %d" , requested_nodes )
288
- self .logger .info (
289
- "Nodes scheduled but not requested yet: %d" , len (self .scheduler .requests ))
290
- self .logger .info ("Total nodes timed out: %d" , self ._total_timeouts )
282
+ msg = "processed: %11d, " % self ._total_processed_nodes
283
+ msg += "tnps: %5d, " % (self ._total_processed_nodes / self ._timer .elapsed )
284
+ msg += "committed: %11d, " % self .scheduler .committed_nodes
285
+ msg += "requested: %7d, " % requested_nodes
286
+ msg += "scheduled: %7d, " % len (self .scheduler .requests )
287
+ msg += "timeouts: %5d, " % self ._total_timeouts
288
+ self .logger .info ("State sync progress: %s" , msg )
291
289
try :
292
290
await self .sleep (self ._report_interval )
293
291
except OperationCancelled :
0 commit comments