From 51e8a4820f9f38433c9e2728a05c064f81e24d0d Mon Sep 17 00:00:00 2001 From: evan slack <51209817+evanofslack@users.noreply.github.com> Date: Wed, 28 Jan 2026 21:13:36 -0500 Subject: [PATCH] fix: map unversioned destination replication error correctly (#1645) --- crates/ecstore/src/bucket/bucket_target_sys.rs | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/crates/ecstore/src/bucket/bucket_target_sys.rs b/crates/ecstore/src/bucket/bucket_target_sys.rs index 57d034d3c..e5eccf385 100644 --- a/crates/ecstore/src/bucket/bucket_target_sys.rs +++ b/crates/ecstore/src/bucket/bucket_target_sys.rs @@ -431,13 +431,15 @@ impl BucketTargetSys { let versioning = target_client .get_bucket_versioning(&target.target_bucket) .await - .map_err(|_e| BucketTargetError::BucketReplicationSourceNotVersioned { - bucket: bucket.to_string(), + .map_err(|e| BucketTargetError::RemoteTargetConnectionErr { + bucket: target.target_bucket.clone(), + access_key: target.credentials.as_ref().map(|c| c.access_key.clone()).unwrap_or_default(), + error: e.to_string(), })?; if versioning.is_none() { - return Err(BucketTargetError::BucketReplicationSourceNotVersioned { - bucket: bucket.to_string(), + return Err(BucketTargetError::BucketRemoteTargetNotVersioned { + bucket: target.target_bucket.to_string(), }); } }