Skip to content

Commit 89fe808

Browse files
committed
fix: disable lazy vss deletes, re-add ConflictError to skip retry matching
1 parent 5805799 commit 89fe808

File tree

1 file changed

+9
-3
lines changed

1 file changed

+9
-3
lines changed

src/io/vss_store.rs

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -684,11 +684,12 @@ impl VssStoreInner {
684684
self.build_obfuscated_key(&primary_namespace, &secondary_namespace, &key);
685685

686686
let key_value = KeyValue { key: obfuscated_key, version: -1, value: vec![] };
687-
if lazy {
687+
// Alby: disable lazy deletes (can cause a conflict error in the VSS server)
688+
/*if lazy {
688689
let mut pending_lazy_deletes = self.pending_lazy_deletes.lock().unwrap();
689690
pending_lazy_deletes.push(key_value);
690691
return Ok(());
691-
}
692+
}*/
692693

693694
self.execute_locked_write(inner_lock_ref, locking_key, version, async move || {
694695
let request =
@@ -791,7 +792,12 @@ fn retry_policy() -> CustomRetryPolicy {
791792
.with_max_total_delay(Duration::from_secs(180))
792793
.with_max_jitter(Duration::from_millis(100))
793794
.skip_retry_on_error(Box::new(|e: &VssError| {
794-
matches!(e, VssError::NoSuchKeyError(..) | VssError::InvalidRequestError(..))
795+
matches!(
796+
e,
797+
VssError::NoSuchKeyError(..)
798+
| VssError::InvalidRequestError(..)
799+
| VssError::ConflictError(..)
800+
)
795801
}) as _)
796802
}
797803

0 commit comments

Comments
 (0)