diff --git a/sdk/cosmos/azure_data_cosmos_driver/src/driver/pipeline/operation_pipeline.rs b/sdk/cosmos/azure_data_cosmos_driver/src/driver/pipeline/operation_pipeline.rs index b02fdb947ed..f7eaa2ee08d 100644 --- a/sdk/cosmos/azure_data_cosmos_driver/src/driver/pipeline/operation_pipeline.rs +++ b/sdk/cosmos/azure_data_cosmos_driver/src/driver/pipeline/operation_pipeline.rs @@ -850,7 +850,7 @@ pub(crate) async fn execute_operation_pipeline( retry_state.pending_write_effects.clear(); } - tracing::error!( + tracing::debug!( activity_id = %activity_id, status = ?cosmos_status, error = %error, @@ -2443,12 +2443,12 @@ fn finalize_hedge_attempt( body, .. } => { - tracing::warn!( + tracing::debug!( activity_id = %diagnostics.activity_id(), request_count = diagnostics.request_count(), http_status = u16::from(status.status_code()), sub_status = ?status.sub_status(), - "cosmos.hedge.terminal_http_error", + "non-retriable http error in hedging attempt", ); let diagnostics_ctx = Arc::new(diagnostics.complete()); let base = build_service_error(&status, &cosmos_headers, &body); @@ -2457,11 +2457,11 @@ fn finalize_hedge_attempt( .build()) } TransportOutcome::TransportError { error, .. } => { - tracing::warn!( + tracing::debug!( activity_id = %diagnostics.activity_id(), request_count = diagnostics.request_count(), error = %error, - "cosmos.hedge.terminal_transport_error", + "non-retriable transport error in hedging attempt", ); let diagnostics_ctx = Arc::new(diagnostics.complete()); Err(crate::error::CosmosErrorBuilder::from_error(error) @@ -2472,7 +2472,7 @@ fn finalize_hedge_attempt( tracing::warn!( activity_id = %diagnostics.activity_id(), request_count = diagnostics.request_count(), - "cosmos.hedge.terminal_deadline_exceeded", + "deadline exceeded in hedging attempt", ); // Typed status (408 + CLIENT_OPERATION_TIMEOUT) mirrors // `enforce_deadline_or_timeout` so retry-evaluation and