Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 6 additions & 1 deletion src/io/vss_store.rs
Original file line number Diff line number Diff line change
Expand Up @@ -475,10 +475,15 @@ impl VssStoreInner {
version: vss_version,
value: storable.encode_to_vec(),
}],
delete_items,
delete_items: delete_items.clone(),
};

self.client.put_object(&request).await.map_err(|e| {
// Restore delete items so they'll be retried on next write.
Comment thread
joostjager marked this conversation as resolved.
if !delete_items.is_empty() {
self.pending_lazy_deletes.lock().unwrap().extend(delete_items);
}

let msg = format!(
"Failed to write to key {}/{}/{}: {}",
primary_namespace, secondary_namespace, key, e
Expand Down