Update Core

Author: Sushisource

temporalio/bridge/Cargo.lock

@@ -19,7 +19,6 @@ crate-type = ["cdylib"]
 anyhow = "1.0"
 async-trait = "0.1"
 futures = "0.3"
-log = "0.4"
 prost = "0.13"
 pyo3 = { version = "0.25", features = [
     "extension-module",
@@ -28,14 +27,14 @@ pyo3 = { version = "0.25", features = [
 ] }
 pyo3-async-runtimes = { version = "0.25", features = ["tokio-runtime"] }
 pythonize = "0.25"
-temporal-client = { version = "0.1.0", path = "../../../sdk-core/client" }
-temporal-sdk-core = { version = "0.1.0", path = "../../../sdk-core/core", features = [
+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", features = [
+temporal-sdk-core-api = { version = "0.1.0", path = "./sdk-core/core-api", features = [
     "envconfig",
 ] }
-temporal-sdk-core-protos = { version = "0.1.0", path = "../../../sdk-core/sdk-core-protos" }
+temporal-sdk-core-protos = { version = "0.1.0", path = "./sdk-core/sdk-core-protos" }
 tokio = "1.26"
 tokio-stream = "0.1"
 tonic = "0.13"

temporalio/bridge/Cargo.toml

@@ -1,7 +1,6 @@
 #![allow(non_local_definitions)] // pymethods annotations causing issues with this lint
 
 use anyhow::Context;
-use log::error;
 use prost::Message;
 use pyo3::exceptions::{PyException, PyRuntimeError, PyValueError};
 use pyo3::prelude::*;
@@ -24,6 +23,7 @@ use temporal_sdk_core_protos::coresdk::{ActivityHeartbeat, ActivityTaskCompletio
 use temporal_sdk_core_protos::temporal::api::history::v1::History;
 use tokio::sync::mpsc::{channel, Sender};
 use tokio_stream::wrappers::ReceiverStream;
+use tracing::error;
 
 use crate::client;
 use crate::runtime;
@@ -365,9 +365,7 @@ impl<SK: SlotKind + Send + Sync> SlotSupplierTrait for CustomSlotSupplierOfType<
             }) {
                 Ok(f) => f,
                 Err(e) => {
-                    error!(
-                        "Unexpected error in custom slot supplier `reserve_slot`: {e}"
-                    );
+                    error!("Unexpected error in custom slot supplier `reserve_slot`: {e}");
                     continue;
                 }
             }
@@ -400,9 +398,7 @@ impl<SK: SlotKind + Send + Sync> SlotSupplierTrait for CustomSlotSupplierOfType<
             )))
         })
         .unwrap_or_else(|e| {
-            error!(
-                "Uncaught error in custom slot supplier `try_reserve_slot`: {e}"
-            );
+            error!("Uncaught error in custom slot supplier `try_reserve_slot`: {e}");
             None
         })
     }
@@ -424,9 +420,7 @@ impl<SK: SlotKind + Send + Sync> SlotSupplierTrait for CustomSlotSupplierOfType<
             )?;
             PyResult::Ok(())
         }) {
-            error!(
-                "Uncaught error in custom slot supplier `mark_slot_used`: {e}"
-            );
+            error!("Uncaught error in custom slot supplier `mark_slot_used`: {e}");
         }
     }
 
@@ -446,9 +440,7 @@ impl<SK: SlotKind + Send + Sync> SlotSupplierTrait for CustomSlotSupplierOfType<
             py_obj.call_method1("release_slot", (SlotReleaseCtx { slot_info, permit },))?;
             PyResult::Ok(())
         }) {
-            error!(
-                "Uncaught error in custom slot supplier `release_slot`: {e}"
-            );
+            error!("Uncaught error in custom slot supplier `release_slot`: {e}");
         }
     }