@@ -257,8 +257,6 @@ impl<RT: Runtime> Committer<RT> {
257
257
span_commit_id = Some ( commit_id) ;
258
258
Span :: root( "bump_max_repeatable" , SpanContext :: random( ) )
259
259
} ) ;
260
- let local_span = Span :: enter_with_parent( "queue_bump_max_repeatable" , committer_span) ;
261
- local_span. set_local_parent( ) ;
262
260
// Advance the repeatable read timestamp so non-leaders can
263
261
// establish a recent repeatable snapshot.
264
262
next_bump_wait = None ;
@@ -592,7 +590,7 @@ impl<RT: Runtime> Committer<RT> {
592
590
let outer_span = Span :: enter_with_parent ( "outer_bump_max_repeatable_ts" , root_span) ;
593
591
self . persistence_writes . push_back (
594
592
async move {
595
- let _span = Span :: enter_with_parent ( "inner_bump_max_repeatable_ts" , & outer_span) ;
593
+ let span = Span :: enter_with_parent ( "inner_bump_max_repeatable_ts" , & outer_span) ;
596
594
// The MaxRepeatableTimestamp persistence global ensures all future
597
595
// commits on future leaders will be after new_max_repeatable, and followers
598
596
// can know this timestamp is repeatable.
@@ -601,6 +599,7 @@ impl<RT: Runtime> Committer<RT> {
601
599
PersistenceGlobalKey :: MaxRepeatableTimestamp ,
602
600
new_max_repeatable. into ( ) ,
603
601
)
602
+ . in_span ( span)
604
603
. await ?;
605
604
Ok ( PersistenceWrite :: MaxRepeatableTimestamp {
606
605
new_max_repeatable,
0 commit comments