@@ -221,7 +221,10 @@ def start_async(self) -> Event:
221221 )
222222
223223 if self .wal .state_manager .current_state is None :
224- log .debug ('No recoverable state available, created inital state' )
224+ log .debug (
225+ 'No recoverable state available, created inital state' ,
226+ node = pex (self .address ),
227+ )
225228 block_number = self .chain .block_number ()
226229
227230 state_change = ActionInitChain (
@@ -250,7 +253,11 @@ def start_async(self) -> Event:
250253 # for that given block have been processed, filters can be safely
251254 # installed starting from this position without losing events.
252255 last_log_block_number = views .block_number (self .wal .state_manager .current_state )
253- log .debug ('Restored state from WAL' , last_restored_block = last_log_block_number )
256+ log .debug (
257+ 'Restored state from WAL' ,
258+ last_restored_block = last_log_block_number ,
259+ node = pex (self .address ),
260+ )
254261
255262 # Restore the current snapshot group
256263 self .snapshot_group = last_log_block_number // SNAPSHOT_BLOCK_COUNT
@@ -283,6 +290,7 @@ def start_async(self) -> Event:
283290 log .debug (
284291 'Processing pending transactions' ,
285292 num_pending_transactions = len (pending_transactions ),
293+ node = pex (self .address ),
286294 )
287295 with self .dispatch_events_lock :
288296 for transaction in pending_transactions :
0 commit comments