Retry streaming downloads on broken pipe errors (#13281)

Educated guess at #12359 See adab70fd9f/src/proto/streams/state.rs (L309-L310) for the error source.
2025-08-04 10:58:28 +00:00 · 2025-05-04 14:56:15 +02:00 · 2025-05-04 14:56:15 +02:00 · e2d105d045
commit e2d105d045
parent 96cfca1c8f
2 changed files with 2 additions and 2 deletions
--- a/crates/uv-client/src/base_client.rs
+++ b/crates/uv-client/src/base_client.rs
@ -497,6 +497,7 @@ pub fn is_extended_transient_error(err: &dyn Error) -> bool {
    for io_err in find_sources::<io::Error>(&err) {
        if io_err.kind() == io::ErrorKind::ConnectionReset
            || io_err.kind() == io::ErrorKind::UnexpectedEof
+            || io_err.kind() == io::ErrorKind::BrokenPipe
        {
            trace!("Retrying error: `ConnectionReset` or `UnexpectedEof`");
            return true;
--- a/crates/uv-client/src/cached_client.rs
+++ b/crates/uv-client/src/cached_client.rs
@ -623,8 +623,7 @@ impl CachedClient {
                .await;
            if result
                .as_ref()
-                .err()
-                .is_some_and(|err| is_extended_transient_error(err))
+                .is_err_and(|err| is_extended_transient_error(err))
            {
                let retry_decision = retry_policy.should_retry(start_time, n_past_retries);
                if let reqwest_retry::RetryDecision::Retry { execute_after } = retry_decision {