From aabd80c4128a9efcc88cb93a10bfc6fc14fb5b60 Mon Sep 17 00:00:00 2001 From: Ada Bohm Date: Mon, 2 Feb 2026 16:06:07 +0100 Subject: [PATCH] Info about position when event deserialization failed. --- crates/hyperqueue/src/server/event/journal/read.rs | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/crates/hyperqueue/src/server/event/journal/read.rs b/crates/hyperqueue/src/server/event/journal/read.rs index 262a3d916..0c1620d6e 100644 --- a/crates/hyperqueue/src/server/event/journal/read.rs +++ b/crates/hyperqueue/src/server/event/journal/read.rs @@ -67,7 +67,7 @@ impl JournalReader { } impl Iterator for &mut JournalReader { - type Item = Result; + type Item = Result; fn next(&mut self) -> Option { self.position = self.source.stream_position().unwrap(); @@ -83,7 +83,10 @@ impl Iterator for &mut JournalReader { self.partial_data_error = true; None } - _ => Some(Err(error)), + _ => Some(Err(anyhow!( + "Load journal event failed at position: {}. Deserialization error: {error:?}", + self.position + ))), }, } }