Merge pull request #47 from xmakro/main

Upgrade to arrow 52

snowflake-api/Cargo.toml

@@ -9,7 +9,7 @@ license = "Apache-2.0"
 name = "snowflake-api"
 readme = "README.md"
 repository = "https://github.com/mycelial/snowflake-rs"
-version = "0.8.1"
+version = "0.9.0"
 
 [features]
 all = ["cert-auth", "polars"]
@@ -19,7 +19,7 @@ default = ["cert-auth"]
 polars = ["dep:polars-core", "dep:polars-io"]
 
 [dependencies]
-arrow = "51"
+arrow = "52"
 async-trait = "0.1"
 base64 = "0.22"
 bytes = "1"
@@ -49,12 +49,12 @@ polars-io = { version = ">=0.32", features = [
 
 # put request support
 glob = { version = "0.3" }
-object_store = { version = "0.9", features = ["aws"] }
+object_store = { version = "0.10", features = ["aws"] }
 tokio = { version = "1", features = ["macros", "rt-multi-thread"] }
 
 [dev-dependencies]
 anyhow = "1"
-arrow = { version = "51", features = ["prettyprint"] }
+arrow = { version = "52", features = ["prettyprint"] }
 clap = { version = "4", features = ["derive"] }
 pretty_env_logger = "0.5"
 tokio = { version = "1.35", features = ["macros", "rt-multi-thread"] }

snowflake-api/examples/tracing/Cargo.toml

@@ -5,17 +5,17 @@ version = "0.1.0"
 
 [dependencies]
 anyhow = "1"
-arrow = { version = "51", features = ["prettyprint"] }
+arrow = { version = "52", features = ["prettyprint"] }
 dotenv = "0.15"
 snowflake-api = { path = "../../../snowflake-api" }
 
-opentelemetry = "0.22"
-opentelemetry-otlp = "0.15"
-opentelemetry-semantic-conventions = "0.14"
-opentelemetry_sdk = { version = "0.22", features = ["rt-tokio"] }
+opentelemetry = "0.23"
+opentelemetry-otlp = "0.16"
+opentelemetry-semantic-conventions = "0.15"
+opentelemetry_sdk = { version = "0.23", features = ["rt-tokio"] }
 reqwest-middleware = "0.3"
 reqwest-tracing = { version = "0.5", features = ["opentelemetry_0_21"] }
 tokio = { version = "1", features = ["full"] }
 tracing = "0.1"
-tracing-opentelemetry = "0.23"
+tracing-opentelemetry = "0.24"
 tracing-subscriber = "0.3"

snowflake-api/src/put.rs

@@ -142,7 +142,7 @@ async fn put_file<T: ObjectStore>(
     let src_path = object_store::path::Path::parse(src_path)?;
     let fs = LocalFileSystem::new().get(&src_path).await?;
 
-    store.put(&dest_path, fs.bytes().await?).await?;
+    store.put(&dest_path, fs.bytes().await?.into()).await?;
 
     Ok::<(), SnowflakeApiError>(())
 }