Update Rust crate tarpc to v0.35.0 (#5505)

Co-authored-by: hash-worker[bot] <180894564+hash-worker[bot]@users.noreply.github.com> Co-authored-by: Tim Diekmann <[email protected]>
hashintel · Oct 30, 2024 · 292e515 · 292e515
1 parent a711fc6
commit 292e515
Show file tree

Hide file tree

Showing 6 changed files with 43 additions and 80 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -198,7 +198,7 @@ similar-asserts = { version = "=1.6.0", default-features = false }
 supports-color = { version = "=3.0.1", default-features = false }
 supports-unicode = { version = "=3.0.0", default-features = false }
 tachyonix = { version = "=0.3.1", default-features = false }
-tarpc = { version = "=0.33", default-features = false }
+tarpc = { version = "=0.35.0", default-features = false }
 temporal-io-client = { package = "temporal-client", git = "https://github.com/temporalio/sdk-core", rev = "7e3c23f" }
 temporal-io-sdk-core-protos = { package = "temporal-sdk-core-protos", git = "https://github.com/temporalio/sdk-core", rev = "7e3c23f" }
 test-fuzz = { version = "=6.0.0", default-features = false }

diff --git a/apps/hash-graph/bins/cli/src/subcommand/type_fetcher.rs b/apps/hash-graph/bins/cli/src/subcommand/type_fetcher.rs
@@ -91,7 +91,11 @@ pub async fn type_fetcher(args: TypeFetcherArgs) -> Result<(), GraphError> {
             server
                 .load_predefined_types()
                 .expect("should be able to load predefined types");
-            channel.execute(server.serve())
+            channel
+                .execute(server.serve())
+                .for_each(|response| async move {
+                    tokio::spawn(response);
+                })
         })
         .buffer_unordered(255)
         .for_each(|()| async {})

diff --git a/apps/hash-graph/libs/type-fetcher/Cargo.toml b/apps/hash-graph/libs/type-fetcher/Cargo.toml
@@ -14,6 +14,7 @@ description = "RPC service definition to fetch external BP types"
 type-system = { workspace = true, public = true }
 
 # Public third-party dependencies
+tarpc = { workspace = true, public = true, features = ["tokio1"] }
 time = { workspace = true, public = true, features = ["serde", "std"] }
 serde_json = { workspace = true, public = true }
 
@@ -25,7 +26,6 @@ futures = { workspace = true }
 include_dir = { workspace = true, features = ["glob"] }
 reqwest = { workspace = true, features = ["json"] }
 serde = { workspace = true, features = ["derive"] }
-tarpc = { workspace = true, features = ["tokio1"] }
 tracing = { workspace = true }
 
 [lints]

diff --git a/apps/hash-graph/libs/type-fetcher/src/fetcher.rs b/apps/hash-graph/libs/type-fetcher/src/fetcher.rs
@@ -1,3 +1,5 @@
+#![expect(clippy::future_not_send)]
+
 use core::{error::Error, fmt};
 
 use serde::{Deserialize, Serialize};

diff --git a/apps/hash-graph/libs/type-fetcher/src/fetcher_server.rs b/apps/hash-graph/libs/type-fetcher/src/fetcher_server.rs
@@ -62,7 +62,6 @@ impl FetchServer {
     }
 }
 
-#[tarpc::server]
 impl Fetcher for FetchServer {
     async fn fetch_ontology_types(
         self,
-Original file line number
+Diff line change
@@ Expand Up / @@ -62,7 +62,6 @@ impl FetchServer { @@
         }
     }
-    #[tarpc::server]
     impl Fetcher for FetchServer {
         async fn fetch_ontology_types(
             self,
@@ Expand Down @@