diff --git a/libs/collab-rt/src/collaborate/group_broadcast.rs b/libs/collab-rt/src/collaborate/group_broadcast.rs index 2735fc9d..9eb9874e 100644 --- a/libs/collab-rt/src/collaborate/group_broadcast.rs +++ b/libs/collab-rt/src/collaborate/group_broadcast.rs @@ -420,7 +420,6 @@ async fn handle_one_message_payload( metrics_calculate .apply_update_failed_count .fetch_add(1, Ordering::Relaxed); - error!("{} protocol error:{}", object_id, err); if ack_response.is_none() { let resp = CollabAck::new( message_origin.clone(), diff --git a/src/biz/snapshot/snapshot_control.rs b/src/biz/snapshot/snapshot_control.rs index 85a03cf3..6ab92df8 100644 --- a/src/biz/snapshot/snapshot_control.rs +++ b/src/biz/snapshot/snapshot_control.rs @@ -289,7 +289,7 @@ impl SnapshotCommandRunner { Ok(()) }, Err(e) => { - self.queue.write().await.push_item(next_item); + // self.queue.write().await.push_item(next_item); Err(e) }, }