chore: update dependencies

Cargo.toml

@@ -101,11 +101,11 @@ blocks_in_conditions = "allow" # opentelemetry tracing macro would be noisy
 
 [workspace.dependencies]
 actix-cors = { version = "0.7" }
-actix-multipart = { version = "0.6", features = ["derive", "tempfile"] }
+actix-multipart = { version = "0.7", features = ["derive", "tempfile"] }
 actix-web = { version = "4.6", default-features = false, features = ["macros"] }
 actix-web-opentelemetry = { version = "0.18", features = ["metrics"] }
 anyhow = { version = "1.0", features = ["backtrace"] }
-arrow = { version = "51" } # should be synced with deltalake and lancedb
+arrow = { version = "52" } # should be synced with deltalake and lancedb
 argon2 = { version = "0.5" }
 async-nats = { version = "0.35", default-features = false, features = [
     "server_2_10",
@@ -122,7 +122,7 @@ chrono = { version = "0.4", features = ["serde"] }
 clap = { version = "4.5", features = ["derive", "env", "string"] }
 csv = { version = "1.3" }
 ctrlc = { version = "3.4" }
-deltalake = { version = "0.17", features = [
+deltalake = { version = "0.18", features = [
     "datafusion",
     "datafusion-ext",
     "json",
@@ -142,7 +142,7 @@ egui = { version = "0.27" }
 egui_graphs = { version = "0.20" }
 email_address = { version = "0.2" }
 futures = { version = "0.3" }
-gethostname = { version = "0.4" }
+gethostname = { version = "0.5" }
 glob = { version = "0.3" }
 hickory-server = { version = "*", default-features = false, features = [
     "backtrace",
@@ -154,15 +154,14 @@ inflector = { package = "Inflector", version = "0.11" }
 ipnet = { version = "2.9", features = ["schemars", "serde"] }
 itertools = { version = "0.13" }
 k8s-openapi = { version = "0.22", features = ["latest", "schemars"] }
-kube = { version = "0.92", default-features = false }
+kube = { version = "0.93", default-features = false }
 lalrpop = { version = "0.20" }
 lalrpop-util = { version = "0.20", features = ["lexer", "unicode"] }
-lancedb = { version = "0.5", default-features = false }
+lancedb = { version = "0.7", default-features = false }
 # langchain-rust = { version = "4.1", default-features = false }
 mime = { version = "0.3" }
 # FIXME: push a PR: rustls-tls feature support
 minio = { git = "https://github.com/ulagbulag/minio-rs.git", version = "0.2.0-alpha", default-features = false } # not deployed to crates.io
-map-macro = { version = "0.3" }
 maplit = { version = "1.0" }
 ndarray = { version = "0.15" }
 num-traits = { version = "0.2" }
@@ -173,18 +172,18 @@ octocrab = { version = "0.38", default-features = false, features = [
 opencv = { version = "0.92", default-features = false, features = [
     "clang-runtime",
 ] }
-opentelemetry = { version = "0.23", features = ["logs", "metrics", "trace"] }
-opentelemetry-appender-tracing = { version = "0.4", features = [
+opentelemetry = { version = "0.24", features = ["logs", "metrics", "trace"] }
+opentelemetry-appender-tracing = { version = "0.5", features = [
     # "experimental_metadata_attributes",
     "logs_level_enabled",
 ] }
-opentelemetry-otlp = { version = "0.16", features = [
+opentelemetry-otlp = { version = "0.17", features = [
     "logs",
     "metrics",
     "trace",
 ] }
-opentelemetry-proto = { version = "0.6", features = ["with-serde", "zpages"] }
-opentelemetry_sdk = { version = "0.23", features = [
+opentelemetry-proto = { version = "0.7", features = ["with-serde", "zpages"] }
+opentelemetry_sdk = { version = "0.24", features = [
     "logs_level_enabled",
     "metrics",
     "rt-tokio",
@@ -205,7 +204,7 @@ ordered-float = { version = "4.2", default-features = false, features = [
     "std",
 ] }
 petgraph = { version = "0.6" }
-polars = { version = "0.40", features = [
+polars = { version = "0.41", features = [
     "diagonal_concat",
     "diff",
     "fmt",
@@ -222,7 +221,7 @@ polars = { version = "0.40", features = [
 ] }
 procfs = { version = "0.16" }
 prometheus-http-query = { version = "0.8", default-features = false }
-pyo3 = { version = "0.21" }
+pyo3 = { version = "0.22" }
 r2r = { version = "0.9" }
 rand = { version = "0.8" }
 rand_distr = { version = "0.4" }
@@ -280,11 +279,11 @@ tera = { version = "1.19" }
 thiserror = { version = "1.0" }
 tokio = { version = "1.37", features = ["macros", "rt"] }
 tokio-stream = { version = "0.1" }
-tonic = { version = "0.11", features = [
+tonic = { version = "0.12", features = [
     "gzip",
 ] } # should be synced with opentelemetry-proto
 tracing = { version = "0.1" }
-tracing-opentelemetry = { version = "0.24", features = [
+tracing-opentelemetry = { version = "0.25", features = [
     "metrics",
     "tracing-log",
 ] } # should be synced with opentelemetry
@@ -301,9 +300,5 @@ winit = { version = "0.29", features = [
 ] } # should be synced with eframe
 
 [patch.crates-io]
-# FIXME: Sync with the components
-deltalake = { git = "https://github.com/delta-io/delta-rs", rev = "rust-v0.17.3" }
-deltalake-aws = { git = "https://github.com/delta-io/delta-rs", rev = "rust-v0.17.3" }
-
 # FIXME: Waiting for PR merged: https://github.com/GREsau/schemars/pull/255
 schemars = { git = "https://github.com/ulagbulag/schemars" }

crates/ark/core/src/tracer.rs

@@ -78,10 +78,13 @@ fn init_once_opentelemetry(export: bool) {
     where
         S: Subscriber + for<'span> LookupSpan<'span>,
     {
+        use opentelemetry::trace::TracerProvider;
+
         otlp::new_pipeline()
             .tracing()
             .with_exporter(init_otlp_pipeline())
             .install_batch(Runtime)
+            .map(|provider| provider.tracer("ark-tracer"))
             .map(::tracing_opentelemetry::OpenTelemetryLayer::new)
             .expect("failed to init a tracer")
     }

crates/dash/pipe/provider/Cargo.toml

@@ -35,7 +35,7 @@ ros2 = ["dep:r2r"]
 
 # storage
 storage = ["deltalake", "s3"]
-deltalake = ["arrow", "dash-api", "dep:deltalake", "inflector", "map-macro"]
+deltalake = ["arrow", "dash-api", "dep:deltalake", "inflector"]
 lancedb = ["arrow", "dep:lancedb", "object_store/aws"]
 s3 = ["chrono", "minio"]
 
@@ -74,7 +74,6 @@ gethostname = { workspace = true }
 inflector = { workspace = true, optional = true }
 kube = { workspace = true }
 lancedb = { workspace = true, optional = true }
-map-macro = { workspace = true, optional = true }
 minio = { workspace = true, optional = true }
 object_store = { workspace = true, optional = true }
 opentelemetry = { workspace = true }