diff --git a/Cargo.lock b/Cargo.lock index 71f3418..091935b 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -515,8 +515,9 @@ dependencies = [ [[package]] name = "restate-sdk-shared-core" -version = "0.6.0" -source = "git+https://github.com/restatedev/sdk-shared-core.git?rev=eafbe4729a4ae7fa74fd0fb32e29121b240e1e5e#eafbe4729a4ae7fa74fd0fb32e29121b240e1e5e" +version = "0.7.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "dc31df792d23376df8d3a6d4264ec3ce658bf68f0ec5296da43de8377c9352aa" dependencies = [ "base64 0.22.1", "bs58", diff --git a/Cargo.toml b/Cargo.toml index 0ac84ad..3d16ceb 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 = "eafbe4729a4ae7fa74fd0fb32e29121b240e1e5e", features = ["request_identity", "sha2_random_seed"] } +restate-sdk-shared-core = { version = "=0.7.0", features = ["request_identity", "sha2_random_seed"] } diff --git a/src/lib.rs b/src/lib.rs index 63c05f1..88c871e 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -424,7 +424,7 @@ impl PyVM { ) -> Result { self_ .vm - .sys_state_get(key) + .sys_state_get(key, Default::default()) .map(Into::into) .map_err(Into::into) } @@ -446,7 +446,7 @@ impl PyVM { ) -> Result<(), PyVMError> { self_ .vm - .sys_state_set(key, buffer.as_bytes().to_vec().into()) + .sys_state_set(key, buffer.as_bytes().to_vec().into(), Default::default()) .map_err(Into::into) } @@ -501,7 +501,7 @@ impl PyVM { .map(Into::into) .collect(), }, - buffer.as_bytes().to_vec().into(), + buffer.as_bytes().to_vec().into(),Default::default() ) .map(Into::into) .map_err(Into::into) @@ -539,7 +539,8 @@ impl PyVM { .duration_since(SystemTime::UNIX_EPOCH) .expect("Duration since unix epoch cannot fail") + Duration::from_millis(millis) - }), + }) + , Default::default() ) .map(|s| s.invocation_id_notification_handle.into()) .map_err(Into::into) @@ -565,6 +566,7 @@ impl PyVM { .sys_complete_awakeable( id, NonEmptyValue::Success(buffer.as_bytes().to_vec().into()), + Default::default() ) .map_err(Into::into) } @@ -576,7 +578,7 @@ impl PyVM { ) -> Result<(), PyVMError> { self_ .vm - .sys_complete_awakeable(id, NonEmptyValue::Failure(value.into())) + .sys_complete_awakeable(id, NonEmptyValue::Failure(value.into()), Default::default()) .map_err(Into::into) } @@ -611,7 +613,7 @@ impl PyVM { .vm .sys_complete_promise( key, - NonEmptyValue::Success(buffer.as_bytes().to_vec().into()), + NonEmptyValue::Success(buffer.as_bytes().to_vec().into()),Default::default() ) .map(Into::into) .map_err(Into::into) @@ -624,7 +626,7 @@ impl PyVM { ) -> Result { self_ .vm - .sys_complete_promise(key, NonEmptyValue::Failure(value.into())) + .sys_complete_promise(key, NonEmptyValue::Failure(value.into()),Default::default()) .map(Into::into) .map_err(Into::into) } @@ -699,7 +701,7 @@ impl PyVM { ) -> Result<(), PyVMError> { self_ .vm - .sys_write_output(NonEmptyValue::Success(buffer.as_bytes().to_vec().into())) + .sys_write_output(NonEmptyValue::Success(buffer.as_bytes().to_vec().into()),Default::default()) .map_err(Into::into) } @@ -709,7 +711,7 @@ impl PyVM { ) -> Result<(), PyVMError> { self_ .vm - .sys_write_output(NonEmptyValue::Failure(value.into())) + .sys_write_output(NonEmptyValue::Failure(value.into()),Default::default()) .map_err(Into::into) }