File tree 3 files changed +6
-7
lines changed
3 files changed +6
-7
lines changed Original file line number Diff line number Diff line change @@ -11,13 +11,14 @@ use signet_sim::SimCache;
11
11
use signet_types:: SlotCalculator ;
12
12
use std:: sync:: Arc ;
13
13
use tokio:: select;
14
+ use tracing:: info_span;
14
15
15
16
// Note: Must be set to `multi_thread` to support async tasks.
16
17
// See: https://docs.rs/tokio/latest/tokio/attr.main.html
17
18
#[ tokio:: main( flavor = "multi_thread" ) ]
18
19
async fn main ( ) -> eyre:: Result < ( ) > {
19
20
let _guard = init4_bin_base:: init4 ( ) ;
20
- let init_span_guard = tracing :: info_span!( "builder initialization" ) ;
21
+ let init_span_guard = info_span ! ( "builder initialization" ) ;
21
22
22
23
let config = BuilderConfig :: load_from_env ( ) ?. clone ( ) ;
23
24
let constants = config. load_pecorino_constants ( ) ;
Original file line number Diff line number Diff line change @@ -7,7 +7,7 @@ use signet_bundle::SignetEthBundle;
7
7
use tokio:: sync:: mpsc:: { UnboundedReceiver , UnboundedSender , unbounded_channel} ;
8
8
use tokio:: task:: JoinHandle ;
9
9
use tokio:: time;
10
- use tracing:: { Instrument , debug, trace} ;
10
+ use tracing:: { Instrument , debug, trace, warn } ;
11
11
12
12
pub use crate :: config:: BuilderConfig ;
13
13
@@ -60,7 +60,7 @@ impl BundlePoller {
60
60
pub async fn check_bundle_cache ( & mut self ) -> eyre:: Result < Vec < Bundle > > {
61
61
let bundle_url: Url = Url :: parse ( & self . config . tx_pool_url ) ?. join ( "bundles" ) ?;
62
62
let Some ( token) = self . token . read ( ) else {
63
- tracing :: warn!( "No token available, skipping bundle fetch" ) ;
63
+ warn ! ( "No token available, skipping bundle fetch" ) ;
64
64
return Ok ( vec ! [ ] ) ;
65
65
} ;
66
66
Original file line number Diff line number Diff line change @@ -73,17 +73,15 @@ pub struct SubmitTask {
73
73
}
74
74
75
75
impl SubmitTask {
76
+ #[ instrument( skip( self ) ) ]
76
77
async fn sup_quincey ( & self , sig_request : & SignRequest ) -> eyre:: Result < SignResponse > {
77
78
tracing:: info!(
78
79
host_block_number = %sig_request. host_block_number,
79
80
ru_chain_id = %sig_request. ru_chain_id,
80
81
"pinging quincey for signature"
81
82
) ;
82
83
83
- let Some ( token) = self . token . read ( ) else {
84
- tracing:: error!( "no token available" ) ;
85
- return Err ( eyre ! ( "no token available" ) ) ;
86
- } ;
84
+ let Some ( token) = self . token . read ( ) else { bail ! ( "no token available" ) } ;
87
85
88
86
let resp: reqwest:: Response = self
89
87
. client
You can’t perform that action at this time.
0 commit comments