Update Core (#302)

Author: cretz

temporalio/Cargo.lock

@@ -13,17 +13,11 @@ license-file = "LICENSE"
 
 [workspace.dependencies]
 derive_builder = "0.20"
-derive_more = { version = "1.0", features = [
-    "constructor",
-    "display",
-    "from",
-    "into",
-    "debug",
-] }
+derive_more = { version = "2.0", features = ["constructor", "display", "from", "into", "debug", "try_into"] }
 thiserror = "2"
-tonic = "0.12"
-tonic-build = "0.12"
-opentelemetry = { version = "0.29", features = ["metrics"] }
+tonic = "0.13"
+tonic-build = "0.13"
+opentelemetry = { version = "0.30", features = ["metrics"] }
 prost = "0.13"
 prost-types = "0.13"
 

temporalio/Cargo.toml

@@ -19,9 +19,9 @@ temporal-client = { version = "0.1.0", path = "./sdk-core/client" }
 temporal-sdk-core = { version = "0.1.0", path = "./sdk-core/core", features = ["ephemeral-server"] }
 temporal-sdk-core-api = { version = "0.1.0", path = "./sdk-core/core-api" }
 temporal-sdk-core-protos = { version = "0.1.0", path = "./sdk-core/sdk-core-protos" }
-tokio = "1.26"
+tokio = "1.37"
 tokio-stream = "0.1"
 tokio-util = "0.7"
-tonic = "0.12"
+tonic = "0.13"
 tracing = "0.1"
 url = "2.2"

temporalio/ext/Cargo.toml

@@ -102,7 +102,7 @@ impl Client {
             .client_version(options.member::<String>(id!("client_version"))?)
             .headers(Some(options.member(id!("rpc_metadata"))?))
             .api_key(options.member(id!("api_key"))?)
-            .identity(options.member(id!("identity"))?);
+            .identity(options.member::<String>(id!("identity"))?);
         if let Some(tls) = tls {
             opts_build.tls_cfg(TlsConfig {
                 client_tls_config: match (

temporalio/ext/sdk-core

@@ -227,6 +227,7 @@ impl Client {
                     WorkflowService,
                     list_worker_deployments
                 ),
+                "list_workers" => rpc_call!(self, callback, call, WorkflowService, list_workers),
                 "list_workflow_executions" => rpc_call!(
                     self,
                     callback,
@@ -284,6 +285,13 @@ impl Client {
                     WorkflowService,
                     record_activity_task_heartbeat_by_id
                 ),
+                "record_worker_heartbeat" => rpc_call!(
+                    self,
+                    callback,
+                    call,
+                    WorkflowService,
+                    record_worker_heartbeat
+                ),
                 "register_namespace" => {
                     rpc_call!(self, callback, call, WorkflowService, register_namespace)
                 }

temporalio/ext/src/client.rs

@@ -169,28 +169,28 @@ trait Instrument: Send + Sync {
     fn record_value(&self, value: Value, attrs: &metrics::MetricAttributes) -> Result<(), Error>;
 }
 
-impl Instrument for Arc<dyn metrics::Counter> {
+impl Instrument for metrics::Counter {
     fn record_value(&self, value: Value, attrs: &metrics::MetricAttributes) -> Result<(), Error> {
         self.add(TryConvert::try_convert(value)?, attrs);
         Ok(())
     }
 }
 
-impl Instrument for Arc<dyn metrics::Histogram> {
+impl Instrument for metrics::Histogram {
     fn record_value(&self, value: Value, attrs: &metrics::MetricAttributes) -> Result<(), Error> {
         self.record(TryConvert::try_convert(value)?, attrs);
         Ok(())
     }
 }
 
-impl Instrument for Arc<dyn metrics::HistogramF64> {
+impl Instrument for metrics::HistogramF64 {
     fn record_value(&self, value: Value, attrs: &metrics::MetricAttributes) -> Result<(), Error> {
         self.record(TryConvert::try_convert(value)?, attrs);
         Ok(())
     }
 }
 
-impl Instrument for Arc<dyn metrics::HistogramDuration> {
+impl Instrument for metrics::HistogramDuration {
     fn record_value(&self, value: Value, attrs: &metrics::MetricAttributes) -> Result<(), Error> {
         let secs = f64::try_convert(value)?;
         if secs < 0.0 {
@@ -201,14 +201,14 @@ impl Instrument for Arc<dyn metrics::HistogramDuration> {
     }
 }
 
-impl Instrument for Arc<dyn metrics::Gauge> {
+impl Instrument for metrics::Gauge {
     fn record_value(&self, value: Value, attrs: &metrics::MetricAttributes) -> Result<(), Error> {
         self.record(TryConvert::try_convert(value)?, attrs);
         Ok(())
     }
 }
 
-impl Instrument for Arc<dyn metrics::GaugeF64> {
+impl Instrument for metrics::GaugeF64 {
     fn record_value(&self, value: Value, attrs: &metrics::MetricAttributes) -> Result<(), Error> {
         self.record(TryConvert::try_convert(value)?, attrs);
         Ok(())