From 2852c1930cd3de740257a765a19d2b43182ddaf3 Mon Sep 17 00:00:00 2001
From: slinkydeveloper <me@slinkydeveloper.com>
Date: Tue, 19 May 2026 18:00:20 +0200
Subject: [PATCH] Bump shared core

---
 Cargo.lock |  2 +-
 Cargo.toml |  2 +-
 src/lib.rs | 27 ++++++++++++++++++++++-----
 3 files changed, 24 insertions(+), 7 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index 4171c91..ff60afb 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -437,7 +437,7 @@ dependencies = [
 [[package]]
 name = "restate-sdk-shared-core"
 version = "0.10.0"
-source = "git+https://github.com/restatedev/sdk-shared-core.git?rev=d8a42ecceab6e7874138b6316e128a09f2de76d1#d8a42ecceab6e7874138b6316e128a09f2de76d1"
+source = "git+https://github.com/restatedev/sdk-shared-core.git?rev=f6f6e4830226161a441dd7f1063e255cdc4052c1#f6f6e4830226161a441dd7f1063e255cdc4052c1"
 dependencies = [
  "base64",
  "bs58",
diff --git a/Cargo.toml b/Cargo.toml
index 5fef3f5..518532f 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -14,4 +14,4 @@ doc = false
 [dependencies]
 pyo3 = { version = "0.25.1", features = ["extension-module"] }
 tracing-subscriber = { version = "0.3", features = ["fmt", "env-filter"] }
-restate-sdk-shared-core = { git = "https://github.com/restatedev/sdk-shared-core.git", rev = "d8a42ecceab6e7874138b6316e128a09f2de76d1", features = ["request_identity", "sha2_random_seed"] }
+restate-sdk-shared-core = { git = "https://github.com/restatedev/sdk-shared-core.git", rev = "f6f6e4830226161a441dd7f1063e255cdc4052c1", features = ["request_identity", "sha2_random_seed"] }
diff --git a/src/lib.rs b/src/lib.rs
index 9070928..f84bb34 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -106,7 +106,12 @@ struct PyFailure {
 impl PyFailure {
     #[new]
     #[pyo3(signature = (code, message, stacktrace=None, metadata=None))]
-    fn new(code: u16, message: String, stacktrace: Option<String>, metadata: Option<Vec<(String, String)>>) -> PyFailure {
+    fn new(
+        code: u16,
+        message: String,
+        stacktrace: Option<String>,
+        metadata: Option<Vec<(String, String)>>,
+    ) -> PyFailure {
         Self {
             code,
             message,
@@ -369,7 +374,12 @@ impl PyVM {
     }
 
     #[pyo3(signature = (error, stacktrace=None, delay_override_ms=None))]
-    fn notify_error(mut self_: PyRefMut<'_, Self>, error: String, stacktrace: Option<String>, delay_override_ms: Option<u64>) {
+    fn notify_error(
+        mut self_: PyRefMut<'_, Self>,
+        error: String,
+        stacktrace: Option<String>,
+        delay_override_ms: Option<u64>,
+    ) {
         let mut error = Error::new(restate_sdk_shared_core::error::codes::INTERNAL, error);
         if let Some(desc) = stacktrace {
             error = error.with_stacktrace(desc);
@@ -541,6 +551,8 @@ impl PyVM {
                     handler,
                     key,
                     idempotency_key,
+                    scope: None,
+                    limit_key: None,
                     headers: headers
                         .unwrap_or_default()
                         .into_iter()
@@ -549,7 +561,7 @@ impl PyVM {
                 },
                 buffer.as_bytes().to_vec().into(),
                 Default::default(),
-                Default::default()
+                Default::default(),
             )
             .map(Into::into)
             .map_err(Into::into)
@@ -575,6 +587,8 @@ impl PyVM {
                     handler,
                     key,
                     idempotency_key,
+                    scope: None,
+                    limit_key: None,
                     headers: headers
                         .unwrap_or_default()
                         .into_iter()
@@ -589,7 +603,7 @@ impl PyVM {
                         + Duration::from_millis(millis)
                 }),
                 Default::default(),
-                Default::default()
+                Default::default(),
             )
             .map(|s| s.invocation_id_notification_handle.into())
             .map_err(Into::into)
@@ -758,7 +772,10 @@ impl PyVM {
         max_retry_attempts_override: Option<u32>,
         max_retry_duration_override_ms: Option<u64>,
     ) -> Result<(), PyVMError> {
-        let retry_policy = if delay_override_ms.is_some() || max_retry_attempts_override.is_some() || max_retry_duration_override_ms.is_some() {
+        let retry_policy = if delay_override_ms.is_some()
+            || max_retry_attempts_override.is_some()
+            || max_retry_duration_override_ms.is_some()
+        {
             RetryPolicy::FixedDelay {
                 interval: delay_override_ms.map(Duration::from_millis),
                 max_attempts: max_retry_attempts_override,