Skip to content

Commit 050d6b5

Browse files
Update shared core (#63)
1 parent f9ea8ea commit 050d6b5

File tree

2 files changed

+4
-16
lines changed

2 files changed

+4
-16
lines changed

Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ pin-project-lite = "0.2"
3434
rand = { version = "0.9", optional = true }
3535
regress = "0.10"
3636
restate-sdk-macros = { version = "0.5", path = "macros" }
37-
restate-sdk-shared-core = { version = "0.3.0", features = ["request_identity", "sha2_random_seed", "http"] }
37+
restate-sdk-shared-core = { git = "https://github.com/restatedev/sdk-shared-core.git", rev = "96b78a6160880cc4b34c56750dd96652e11cd81c", features = ["request_identity", "sha2_random_seed", "http"] }
3838
schemars = { version = "1.0.0-alpha.17", optional = true }
3939
serde = "1.0"
4040
serde_json = "1.0"

src/endpoint/mod.rs

Lines changed: 3 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -148,23 +148,11 @@ pub(crate) enum ErrorInner {
148148
},
149149
}
150150

151-
impl From<restate_sdk_shared_core::SuspendedError> for ErrorInner {
152-
fn from(_: restate_sdk_shared_core::SuspendedError) -> Self {
153-
Self::Suspended
154-
}
155-
}
156-
157-
impl From<restate_sdk_shared_core::SuspendedOrVMError> for ErrorInner {
158-
fn from(value: restate_sdk_shared_core::SuspendedOrVMError) -> Self {
159-
match value {
160-
restate_sdk_shared_core::SuspendedOrVMError::Suspended(e) => e.into(),
161-
restate_sdk_shared_core::SuspendedOrVMError::VM(e) => e.into(),
162-
}
163-
}
164-
}
165-
166151
impl From<CoreError> for Error {
167152
fn from(e: CoreError) -> Self {
153+
if e.is_suspended_error() {
154+
return ErrorInner::Suspended.into();
155+
}
168156
ErrorInner::from(e).into()
169157
}
170158
}

0 commit comments

Comments
 (0)