Skip to content

Commit 6215089

Browse files
committed
fix
1 parent d753d31 commit 6215089

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/message_pool/msgpool/msg_pool.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -559,7 +559,7 @@ where
559559
loop {
560560
match subscriber.recv().await {
561561
Ok(HeadChanges { reverts, applies }) => {
562-
head_change(
562+
if let Err(e) = head_change(
563563
api.as_ref(),
564564
bls_sig_cache.as_ref(),
565565
repub_trigger.clone(),
@@ -570,7 +570,9 @@ where
570570
applies,
571571
)
572572
.await
573-
.context("Error changing head")?;
573+
{
574+
tracing::warn!("Error changing head: {e}");
575+
}
574576
}
575577
Err(RecvError::Lagged(e)) => {
576578
warn!("Head change subscriber lagged: skipping {} events", e);

0 commit comments

Comments
 (0)