Update deps (#1649)

* Add support for JSON and SSE responses to invoke endpoint

* Updated dependencies

* Updated rust version to 1.88.0

* lint

* cargo clippy --fix

* lint

* fix warning

Author: diptanu

Cargo.lock

@@ -26,7 +26,7 @@ httpx = { version = "0.27.2", extras = ["http2"] }
 pydantic = "^2.11"
 prometheus-client = "^0.22.1"
 psutil = "^7.0.0"
-boto3 = "^1.39.14"
+boto3 = "^1.39.15"
 # Adds function-executor binary, utils lib, sdk used in indexify-cli commands.
 # We need to specify the tensorlake version exactly because pip install doesn't respect poetry.lock files.
 tensorlake = "0.2.33"

indexify/poetry.lock

@@ -1,2 +1,2 @@
 [toolchain]
-channel = "1.82.0"
+channel = "1.88.0"

indexify/pyproject.toml

@@ -10,27 +10,26 @@ resolver = "2"
 [dependencies]
 async-stream = "0.3.6"
 serde = { version = "1.0.219", features = ["derive"] }
-serde_json = "1.0.140"
-serde_yaml = "0.9.34"
+serde_json = "1.0.141"
 anyhow = "1.0.98"
 figment = { version = "0.10.19", features = ["yaml", "toml"] }
 clap = { version = "4.5.40", features = ["derive"] }
 tracing = "0.1.41"
 axum = { version = "0.8.4", features = ["multipart", "macros", "tokio"] }
-tokio = { version = "1.45.1", features = ["full"] }
+tokio = { version = "1.47.0", features = ["full"] }
 axum-server = "0.7.2"
 futures = "0.3.31"
 tracing-subscriber = { version = "0.3.19", features = ["env-filter", "json"] }
 utoipa = { version = "5.4.0", features = ["axum_extras", "yaml"] }
 utoipa-swagger-ui = { version = "9.0.2", features = ["axum"] }
 sha2 = "0.10.9"
 nanoid = "0.4.0"
-object_store = { version="0.12.2", features = ["aws"] }
+object_store = { version="0.12.3", features = ["aws"] }
 uuid = { version = "1.17.0", features = ["v4"] }
 tower-http = { version = "0.6.6", default-features = false, features = ["cors", "trace"] }
 bytes = "1.10.1"
 ciborium = "0.2.2"
-rand = "0.9.1"
+rand = "0.9.2"
 hex = "0.4.3"
 hyper = "1.6.0"
 url = "2.5.4"
@@ -42,14 +41,15 @@ opentelemetry-otlp = { version = "0.30.0", features = ["tokio", "metrics", "trac
 axum-tracing-opentelemetry = { version = "0.29.0", features = ["tracing_level_info"] }
 tower-otel-http-metrics = { version = "0.16.0", features = ["axum"] }
 base64 = "0.22.1"
-tonic = "0.13.1"
-prost = "0.13.5"
-tonic-reflection = "0.13.1"
+tonic = "0.14.0"
+prost = "0.14.1"
+tonic-prost = "0.14.0"
+tonic-reflection = "0.14.0"
 tokio-stream = { version = "0.1.17", features = ["sync"] }
 priority-queue = "2.5.0"
 tokio-util = { version = "0.7.15", features = ["full"] }
 if_chain = "1.0.2"
-slatedb = { version="0.6.1" }
+slatedb = { version="0.7.0" }
 rust-embed = { version = "8.7.2", features = ["mime-guess"] }
 pin-project-lite = "0.2.16"
 pin-project = "1.1.10"
@@ -60,7 +60,7 @@ itertools = "0.14.0"
 async-trait = "0.1.88"
 reqwest = { version = "0.12.20", default-features = false, features = ["json", "rustls-tls"] }
 rocksdb = { version = "0.23.0" }
-strum = { version = "0.27.1", features = ["derive"] }
+strum = { version = "0.27.2", features = ["derive"] }
 derive_builder = "0.20.2"
 tempfile = "3.20.0"
 
@@ -74,7 +74,7 @@ tokio = { version = "1.45.1", features = ["full", "test-util"] }
 anyhow = "1.0.98"
 # All features enabled
 vergen = { version = "9.0.6", features = ["build", "cargo", "rustc", "si"] }
-tonic-build = "0.13.1"
+tonic-prost-build = "0.14.0"
 
 [package.metadata.deb]
 maintainer = "Diptanu Gon Choudhury <diptanu@tensorlake.ai>"

rust-toolchain.toml

@@ -32,7 +32,7 @@ fn main() -> Result<()> {
     let proto_files = ["./proto/executor_api.proto"];
     let out_dir = PathBuf::from(env::var("OUT_DIR").unwrap());
 
-    tonic_build::configure()
+    tonic_prost_build::configure()
         .build_client(false) // Don't build client code as it's not needed for now
         .build_server(true)
         .file_descriptor_set_path(out_dir.join("executor_api_descriptor.bin"))

server/Cargo.toml

@@ -1,2 +1,2 @@
 [toolchain]
-channel = "1.82.0"
+channel = "1.88.0"

server/build.rs

@@ -120,9 +120,8 @@ impl BlobStorage {
         let _timer = Timer::start_with_labels(&self.metrics.operations, timer_kvs);
         let mut hasher = Sha256::new();
         let mut hashed_stream = data.map(|item| {
-            item.map(|bytes| {
-                hasher.update(&bytes);
-                bytes
+            item.inspect(|bytes| {
+                hasher.update(bytes);
             })
         });
 

server/rust-toolchain.toml

@@ -59,7 +59,7 @@ impl Serialize for Expression {
     where
         S: Serializer,
     {
-        format!("{}", self).serialize(serializer)
+        format!("{self}").serialize(serializer)
     }
 }
 

server/src/blob_store/mod.rs

@@ -262,8 +262,8 @@ mod tests {
                 }),
                 expected_host_resources_after: Some(HostResources {
                     cpu_ms_per_sec: 1000,
-                    memory_bytes: 1 * 1024 * 1024 * 1024,
-                    disk_bytes: 1 * 1024 * 1024 * 1024,
+                    memory_bytes: 1024 * 1024 * 1024,
+                    disk_bytes: 1024 * 1024 * 1024,
                     gpu: None,
                 }),
             },
@@ -379,8 +379,8 @@ mod tests {
                 }),
                 expected_host_resources_after: Some(HostResources {
                     cpu_ms_per_sec: 1000,
-                    memory_bytes: 1 * 1024 * 1024 * 1024,
-                    disk_bytes: 1 * 1024 * 1024 * 1024,
+                    memory_bytes: 1024 * 1024 * 1024,
+                    disk_bytes: 1024 * 1024 * 1024,
                     gpu: Some(GPUResources {
                         count: 1,
                         model: GPU_MODEL_NVIDIA_A10.to_string(),
@@ -569,8 +569,8 @@ mod tests {
                 description: "free cpu/mem/disk only",
                 host_resources: HostResources {
                     cpu_ms_per_sec: 1000,
-                    memory_bytes: 1 * 1024 * 1024 * 1024,
-                    disk_bytes: 1 * 1024 * 1024 * 1024,
+                    memory_bytes: 1024 * 1024 * 1024,
+                    disk_bytes: 1024 * 1024 * 1024,
                     gpu: None,
                 },
                 fe_resources: FunctionExecutorResources {
@@ -591,8 +591,8 @@ mod tests {
                 description: "free with gpu",
                 host_resources: HostResources {
                     cpu_ms_per_sec: 1000,
-                    memory_bytes: 1 * 1024 * 1024 * 1024,
-                    disk_bytes: 1 * 1024 * 1024 * 1024,
+                    memory_bytes: 1024 * 1024 * 1024,
+                    disk_bytes: 1024 * 1024 * 1024,
                     gpu: Some(GPUResources {
                         count: 1,
                         model: GPU_MODEL_NVIDIA_A10.to_string(),
@@ -622,8 +622,8 @@ mod tests {
                 description: "free with gpu, wrong model",
                 host_resources: HostResources {
                     cpu_ms_per_sec: 1000,
-                    memory_bytes: 1 * 1024 * 1024 * 1024,
-                    disk_bytes: 1 * 1024 * 1024 * 1024,
+                    memory_bytes: 1024 * 1024 * 1024,
+                    disk_bytes: 1024 * 1024 * 1024,
                     gpu: Some(GPUResources {
                         count: 1,
                         model: GPU_MODEL_NVIDIA_A100_40GB.to_string(),
@@ -645,8 +645,8 @@ mod tests {
                 description: "free with gpu, no gpu on host",
                 host_resources: HostResources {
                     cpu_ms_per_sec: 1000,
-                    memory_bytes: 1 * 1024 * 1024 * 1024,
-                    disk_bytes: 1 * 1024 * 1024 * 1024,
+                    memory_bytes: 1024 * 1024 * 1024,
+                    disk_bytes: 1024 * 1024 * 1024,
                     gpu: None,
                 },
                 fe_resources: FunctionExecutorResources {