Upgrade all non-tonic/prost deps (#998)

Author: Sushisource

client/Cargo.toml

@@ -23,20 +23,20 @@ derive_more = { workspace = true }
 bytes = "1.10"
 futures-util = { version = "0.3", default-features = false }
 futures-retry = "0.6.0"
-http = "1.1"
+http = "1.3"
 http-body-util = "0.1"
-hyper = { version = "1.4.1" }
-hyper-util = "0.1.6"
+hyper = { version = "1.7.0" }
+hyper-util = "0.1.16"
 opentelemetry = { workspace = true, features = ["metrics"], optional = true }
 parking_lot = "0.12"
 slotmap = "1.0"
 thiserror = { workspace = true }
-tokio = "1.1"
+tokio = "1.47"
 tonic = { workspace = true, features = ["tls-ring", "tls-native-roots"] }
 tower = { version = "0.5", features = ["util"] }
 tracing = "0.1"
-url = "2.2"
-uuid = { version = "1.1", features = ["v4"] }
+url = "2.5"
+uuid = { version = "1.18", features = ["v4"] }
 
 [dependencies.temporal-sdk-core-protos]
 path = "../sdk-core-protos"
@@ -47,7 +47,7 @@ path = "../core-api"
 [dev-dependencies]
 assert_matches = "1"
 mockall = "0.13"
-rstest = "0.25"
+rstest = "0.26"
 
 [lints]
 workspace = true

core-api/Cargo.toml

@@ -18,19 +18,19 @@ envconfig = ["dep:toml", "dep:serde", "dep:dirs"]
 
 [dependencies]
 async-trait = "0.1"
-dirs = { version = "5.0", optional = true }
+dirs = { version = "6.0", optional = true }
 derive_builder = { workspace = true }
 derive_more = { workspace = true }
 opentelemetry = { workspace = true, optional = true }
 prost = { workspace = true }
 serde = { version = "1.0", features = ["derive"], optional = true }
 serde_json = "1.0"
 thiserror = { workspace = true }
-toml = { version = "0.8", optional = true }
+toml = { version = "0.9", optional = true }
 tonic = { workspace = true }
 tracing = "0.1"
 tracing-core = "0.1"
-url = "2.3"
+url = "2.5"
 
 [dependencies.temporal-sdk-core-protos]
 path = "../sdk-core-protos"
@@ -40,4 +40,4 @@ version = "0.1"
 workspace = true
 
 [dev-dependencies]
-tempfile = "3.8"
+tempfile = "3.21"

core-api/src/lib.rs

@@ -11,6 +11,7 @@ use crate::{
     },
     worker::WorkerConfig,
 };
+use std::sync::Arc;
 use temporal_sdk_core_protos::coresdk::{
     ActivityHeartbeat, ActivityTaskCompletion,
     activity_task::ActivityTask,
@@ -139,6 +140,73 @@ pub trait Worker: Send + Sync {
     async fn finalize_shutdown(self);
 }
 
+#[async_trait::async_trait]
+impl<W> Worker for Arc<W>
+where
+    W: Worker + ?Sized,
+{
+    async fn validate(&self) -> Result<(), WorkerValidationError> {
+        (**self).validate().await
+    }
+
+    async fn poll_workflow_activation(&self) -> Result<WorkflowActivation, PollError> {
+        (**self).poll_workflow_activation().await
+    }
+
+    async fn poll_activity_task(&self) -> Result<ActivityTask, PollError> {
+        (**self).poll_activity_task().await
+    }
+
+    async fn poll_nexus_task(&self) -> Result<NexusTask, PollError> {
+        (**self).poll_nexus_task().await
+    }
+
+    async fn complete_workflow_activation(
+        &self,
+        completion: WorkflowActivationCompletion,
+    ) -> Result<(), CompleteWfError> {
+        (**self).complete_workflow_activation(completion).await
+    }
+
+    async fn complete_activity_task(
+        &self,
+        completion: ActivityTaskCompletion,
+    ) -> Result<(), CompleteActivityError> {
+        (**self).complete_activity_task(completion).await
+    }
+
+    async fn complete_nexus_task(
+        &self,
+        completion: NexusTaskCompletion,
+    ) -> Result<(), CompleteNexusError> {
+        (**self).complete_nexus_task(completion).await
+    }
+
+    fn record_activity_heartbeat(&self, details: ActivityHeartbeat) {
+        (**self).record_activity_heartbeat(details)
+    }
+
+    fn request_workflow_eviction(&self, run_id: &str) {
+        (**self).request_workflow_eviction(run_id)
+    }
+
+    fn get_config(&self) -> &WorkerConfig {
+        (**self).get_config()
+    }
+
+    fn initiate_shutdown(&self) {
+        (**self).initiate_shutdown()
+    }
+
+    async fn shutdown(&self) {
+        (**self).shutdown().await
+    }
+
+    async fn finalize_shutdown(self) {
+        panic!("Can't finalize shutdown on Arc'd worker")
+    }
+}
+
 macro_rules! dbg_panic {
   ($($arg:tt)*) => {
       use tracing::error;

core-c-bridge/Cargo.toml

@@ -11,21 +11,21 @@ crate-type = ["cdylib"]
 anyhow = "1.0"
 async-trait = "0.1"
 futures-util = { version = "0.3", default-features = false }
-http = "1.1"
+http = "1.3"
 libc = "0.2"
 prost = { workspace = true }
 # We rely on Cargo semver rules not updating a 0.x to 0.y. Per the rand
 # documentation, before 1.0, minor 0.x updates _can_ break portability which can
 # cause non-determinism.
-rand = "0.8.5"
-rand_pcg = "0.3.1"
+rand = "0.9.2"
+rand_pcg = "0.9.0"
 serde_json = "1.0"
-tokio = "1.26"
+tokio = "1.47"
 tokio-stream = "0.1"
 tokio-util = "0.7"
 tonic = { workspace = true }
 tracing = "0.1"
-url = "2.2"
+url = "2.5"
 
 [dependencies.temporal-client]
 path = "../client"

core-c-bridge/src/random.rs

@@ -32,9 +32,9 @@ pub extern "C" fn temporal_core_random_int32_range(
 ) -> i32 {
     let random = unsafe { &mut *random };
     if max_inclusive {
-        random.rand.gen_range(min..=max)
+        random.rand.random_range(min..=max)
     } else {
-        random.rand.gen_range(min..max)
+        random.rand.random_range(min..max)
     }
 }
 
@@ -47,9 +47,9 @@ pub extern "C" fn temporal_core_random_double_range(
 ) -> f64 {
     let random = unsafe { &mut *random };
     if max_inclusive {
-        random.rand.gen_range(min..=max)
+        random.rand.random_range(min..=max)
     } else {
-        random.rand.gen_range(min..max)
+        random.rand.random_range(min..max)
     }
 }
 

core/Cargo.toml

@@ -28,28 +28,28 @@ console-subscriber = { version = "0.4", optional = true }
 crossbeam-channel = "0.5"
 crossbeam-queue = "0.3"
 crossbeam-utils = "0.8"
-dashmap = "6.0"
+dashmap = "6.1"
 derive_builder = { workspace = true }
 derive_more = { workspace = true }
 enum_dispatch = "0.3"
 enum-iterator = "2"
-flate2 = { version = "1.0", optional = true }
+flate2 = { version = "1.1", optional = true }
 futures-util = { version = "0.3", default-features = false }
 futures-channel = { version = "0.3", default-features = false, features = ["std"] }
 gethostname = "1.0.2"
-governor = "0.8"
+governor = "0.10"
 http-body-util = { version = "0.1", optional = true }
-hyper = { version = "1.2", optional = true }
+hyper = { version = "1.7", optional = true }
 hyper-util = { version = "0.1", features = ["server", "http1", "http2", "tokio"], optional = true }
 itertools = "0.14"
-lru = "0.13"
+lru = "0.16"
 mockall = "0.13"
 opentelemetry = { workspace = true, features = ["metrics"], optional = true }
 opentelemetry_sdk = { version = "0.30", features = ["rt-tokio", "metrics", "spec_unstable_metrics_views"], optional = true }
 opentelemetry-otlp = { version = "0.30", features = ["tokio", "metrics", "tls", "http-proto", "grpc-tonic"], optional = true }
 parking_lot = { version = "0.12", features = ["send_guard"] }
 pid = "4.0"
-pin-project = "1.0"
+pin-project = "1.1"
 prometheus = { version = "0.14", optional = true }
 prost = { workspace = true }
 prost-types = { version = "0.6", package = "prost-wkt-types" }
@@ -60,18 +60,18 @@ serde = "1.0"
 serde_json = "1.0"
 siphasher = "1.0"
 slotmap = "1.0"
-sysinfo = { version = "0.33", default-features = false, features = ["system"] }
+sysinfo = { version = "0.37", default-features = false, features = ["system"] }
 tar = { version = "0.4", optional = true }
 thiserror = { workspace = true }
-tokio = { version = "1.37", features = ["rt", "rt-multi-thread", "parking_lot", "time", "fs", "process"] }
+tokio = { version = "1.47", features = ["rt", "rt-multi-thread", "parking_lot", "time", "fs", "process"] }
 tokio-util = { version = "0.7", features = ["io", "io-util"] }
 tokio-stream = "0.1"
 tonic = { workspace = true, features = ["tls-ring", "tls-native-roots"] }
 tracing = "0.1"
 tracing-subscriber = { version = "0.3", default-features = false, features = ["parking_lot", "env-filter", "registry", "ansi"] }
-url = "2.2"
-uuid = { version = "1.1", features = ["v4"] }
-zip = { version = "2.0", optional = true }
+url = "2.5"
+uuid = { version = "1.18", features = ["v4"] }
+zip = { version = "4.6", optional = true }
 
 # 1st party local deps
 [dependencies.temporal-sdk-core-api]
@@ -89,14 +89,14 @@ path = "../client"
 path = "../fsm"
 
 [dev-dependencies]
-assert_matches = "1.4"
-bimap = "0.6.1"
-clap = { version = "4.0", features = ["derive"] }
-criterion = { version = "0.6", features = ["async", "async_tokio"] }
-rstest = "0.25"
+assert_matches = "1.5"
+bimap = "0.6.3"
+clap = { version = "4.5", features = ["derive"] }
+criterion = { version = "0.7", features = ["async", "async_tokio"] }
+rstest = "0.26"
 temporal-sdk-core-test-utils = { path = "../test-utils" }
 temporal-sdk = { path = "../sdk" }
-tokio = { version = "1.37", features = ["rt", "rt-multi-thread", "parking_lot", "time", "fs", "process", "test-util"] }
+tokio = { version = "1.47", features = ["rt", "rt-multi-thread", "parking_lot", "time", "fs", "process", "test-util"] }
 tokio-stream = { version = "0.1", features = ["net"] }
 
 [[test]]

core/src/test_help/mod.rs

@@ -1065,30 +1065,7 @@ pub(crate) trait WorkerExt {
 #[async_trait]
 impl WorkerExt for Worker {
     async fn drain_pollers_and_shutdown(self) {
-        self.initiate_shutdown();
-        tokio::join!(
-            async {
-                assert_matches!(
-                    self.poll_activity_task().await.unwrap_err(),
-                    PollError::ShutDown
-                );
-            },
-            async {
-                loop {
-                    match self.poll_workflow_activation().await {
-                        Err(PollError::ShutDown) => break,
-                        Ok(a) if a.is_only_eviction() => {
-                            self.complete_workflow_activation(WorkflowActivationCompletion::empty(
-                                a.run_id,
-                            ))
-                            .await
-                            .unwrap();
-                        }
-                        o => panic!("Unexpected activation while draining: {o:?}"),
-                    }
-                }
-            }
-        );
+        temporal_sdk_core_test_utils::drain_pollers_and_shutdown(&self).await;
         self.finalize_shutdown().await;
     }
 

sdk-core-protos/Cargo.toml

@@ -26,7 +26,7 @@ serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 thiserror = { workspace = true }
 tonic = { workspace = true }
-uuid = { version = "1.1", features = ["v4"], optional = true }
+uuid = { version = "1.18", features = ["v4"], optional = true }
 
 [build-dependencies]
 tonic-build = { workspace = true }

sdk/Cargo.toml

@@ -18,7 +18,7 @@ futures-util = { version = "0.3", default-features = false }
 parking_lot = { version = "0.12", features = ["send_guard"] }
 prost-types = { version = "0.6", package = "prost-wkt-types" }
 serde = "1.0"
-tokio = { version = "1.26", features = ["rt", "rt-multi-thread", "parking_lot", "time", "fs"] }
+tokio = { version = "1.47", features = ["rt", "rt-multi-thread", "parking_lot", "time", "fs"] }
 tokio-util = { version = "0.7" }
 tokio-stream = "0.1"
 tracing = "0.1"

test-utils/Cargo.toml

@@ -19,9 +19,9 @@ assert_matches = "1"
 async-trait = "0.1"
 bytes = "1.10"
 futures-util = { version = "0.3", default-features = false }
-hyper = { version = "1.4.1" }
+hyper = { version = "1.7.0" }
 http-body-util = "0.1"
-hyper-util = "0.1.6"
+hyper-util = "0.1.16"
 parking_lot = "0.12"
 prost = { workspace = true }
 rand = "0.9"
@@ -30,9 +30,9 @@ temporal-client = { path = "../client" }
 temporal-sdk = { path = "../sdk" }
 temporal-sdk-core = { path = "../core" }
 temporal-sdk-core-api = { path = "../core-api" }
-tokio = "1.1"
+tokio = "1.47"
 tracing = "0.1"
-url = "2.2"
+url = "2.5"
 
 [dependencies.temporal-sdk-core-protos]
 path = "../sdk-core-protos"