From caae584755ea5234aaaa0e19a7f9201e91b3fff2 Mon Sep 17 00:00:00 2001 From: Vitaly Terekhov Date: Fri, 7 Jun 2024 15:10:51 +0000 Subject: [PATCH] fix(internal-queue-adapter): temporary do not commit msgs to queue --- collator/src/queue_adapter.rs | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/collator/src/queue_adapter.rs b/collator/src/queue_adapter.rs index ce2b208d9..b25853224 100644 --- a/collator/src/queue_adapter.rs +++ b/collator/src/queue_adapter.rs @@ -127,7 +127,9 @@ impl MessageQueueAdapter for MessageQueueAdapterStdImpl { target: tracing_targets::MQ_ADAPTER, "Committing diff to the queue" ); - let diff = self.queue.commit_diff(diff_id).await?; + // HACK: do not commit diff to avoid incorrect msgs set reading for collation + // let diff = self.queue.commit_diff(diff_id).await?; + let diff = None; Ok(diff) } @@ -136,7 +138,7 @@ impl MessageQueueAdapter for MessageQueueAdapterStdImpl { iterator: &mut Box, messages: Vec<(MsgInfo, Cell)>, ) -> Result<()> { - tracing::debug!( + tracing::trace!( target: tracing_targets::MQ_ADAPTER, messages_len = messages.len(), "Adding messages to the iterator"