fix: consume mountpoint-s3-client 0.14.1 (#332)

Update to mountpoint-s3-client v0.14.1 to address CRT timeout issues
and adapt to API changes:
- Include aws-c-s3 first byte timeout fix (awslabs/aws-c-s3/pull/461)
- Update get_object functions to use new GetBodyPart type
  (awslabs/mountpoint-s3/pull/1348)

This addresses AWS_ERROR_HTTP_RESPONSE_FIRST_BYTE_TIMEOUT CRT error.

Author: jet-tong

s3torchconnectorclient/Cargo.lock

@@ -18,7 +18,7 @@ built = "0.7"
 [dependencies]
 pyo3 = "0.24.1"
 futures = "0.3.28"
-mountpoint-s3-client = { version = "0.13.3", features = ["mock"] }
+mountpoint-s3-client = { version = "0.14.1", features = ["mock"] }
 mountpoint-s3-crt-sys = { version = "0.13.0" }
 log = "0.4.20"
 tracing = { version = "0.1.40", default-features = false, features = ["std", "log"] }

s3torchconnectorclient/Cargo.toml

@@ -5,6 +5,7 @@
 
 use pyo3::types::PyBytes;
 use pyo3::{pyclass, pymethods, Bound, PyRef, PyRefMut, PyResult};
+use mountpoint_s3_client::types::GetBodyPart;
 
 use crate::exception::S3Exception;
 use crate::mountpoint_s3_client_inner::MPGetObjectClosure;
@@ -45,7 +46,7 @@ impl GetObjectStream {
         let body_part = (slf.next_part)(py)?;
         match body_part {
             None => Ok(None),
-            Some((offset, data)) => {
+            Some(GetBodyPart { offset, data }) => {
                 if offset != slf.offset {
                     return Err(S3Exception::new_err(
                         "Data from S3 was returned out of order!",

s3torchconnectorclient/rust/src/get_object_stream.rs

@@ -7,7 +7,7 @@ use std::sync::Arc;
 
 use futures::executor::block_on;
 use futures::TryStreamExt;
-use mountpoint_s3_client::types::{CopyObjectParams, GetObjectParams, HeadObjectParams, ListObjectsResult, PutObjectParams};
+use mountpoint_s3_client::types::{GetBodyPart, CopyObjectParams, GetObjectParams, HeadObjectParams, ListObjectsResult, PutObjectParams};
 use mountpoint_s3_client::ObjectClient;
 use pyo3::{PyResult, Python};
 
@@ -17,7 +17,7 @@ use crate::put_object_stream::PutObjectStream;
 use crate::python_structs::py_head_object_result::PyHeadObjectResult;
 
 pub type MPGetObjectClosure =
-    Box<dyn FnMut(Python) -> PyResult<Option<(u64, Box<[u8]>)>> + Send + Sync>;
+    Box<dyn FnMut(Python) -> PyResult<Option<GetBodyPart>> + Send + Sync>;
 
 /// We need an extra trait here, as pyo3 doesn't support structs with generics.
 /// However, it does allow dynamic traits. We can't ues `ObjectClient` itself, as that requires