Skip to content

Commit 5a93116

Browse files
devin-ai-integration[bot]Jayant Krishnamurthy
andcommitted
style: format keeper.rs
Co-Authored-By: Jayant Krishnamurthy <[email protected]>
1 parent 56f4bcd commit 5a93116

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

apps/fortuna/src/keeper.rs

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -105,7 +105,15 @@ pub async fn run_keeper_threads(
105105

106106
let (tx, rx) = mpsc::channel::<BlockRange>(1000);
107107
// Spawn a thread to watch for new blocks and send the range of blocks for which events has not been handled to the `tx` channel.
108-
spawn(watch_blocks_wrapper(chain_state.clone(), latest_safe_block, tx, chain_eth_config.retry_previous_blocks).in_current_span());
108+
spawn(
109+
watch_blocks_wrapper(
110+
chain_state.clone(),
111+
latest_safe_block,
112+
tx,
113+
chain_eth_config.retry_previous_blocks,
114+
)
115+
.in_current_span(),
116+
);
109117

110118
// Spawn a thread for block processing with configured delays
111119
spawn(

0 commit comments

Comments
 (0)