Bump shared core (#197)

Author: slinkydeveloper

Cargo.lock

@@ -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"] }

Cargo.toml

@@ -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,