chore: update log & stop requeue snapshot when first trying is fail
This commit is contained in:
parent
c77329ea11
commit
6137b6a9ab
|
|
@ -420,7 +420,6 @@ async fn handle_one_message_payload(
|
||||||
metrics_calculate
|
metrics_calculate
|
||||||
.apply_update_failed_count
|
.apply_update_failed_count
|
||||||
.fetch_add(1, Ordering::Relaxed);
|
.fetch_add(1, Ordering::Relaxed);
|
||||||
error!("{} protocol error:{}", object_id, err);
|
|
||||||
if ack_response.is_none() {
|
if ack_response.is_none() {
|
||||||
let resp = CollabAck::new(
|
let resp = CollabAck::new(
|
||||||
message_origin.clone(),
|
message_origin.clone(),
|
||||||
|
|
|
||||||
|
|
@ -289,7 +289,7 @@ impl SnapshotCommandRunner {
|
||||||
Ok(())
|
Ok(())
|
||||||
},
|
},
|
||||||
Err(e) => {
|
Err(e) => {
|
||||||
self.queue.write().await.push_item(next_item);
|
// self.queue.write().await.push_item(next_item);
|
||||||
Err(e)
|
Err(e)
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue