Skip to content

Commit 02c09ad

Browse files
authored
Merge branch 'main' into fix-flaky-test
2 parents 0092595 + 9d1bdf9 commit 02c09ad

2 files changed

Lines changed: 10 additions & 1 deletion

File tree

crates/macros/src/workflow_definitions.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1012,7 +1012,7 @@ impl WorkflowMethodsDefinition {
10121012
let result = #run_call;
10131013
match result {
10141014
Ok(value) => ::temporalio_sdk::workflows::serialize_result(value, &ctx.payload_converter())
1015-
.map_err(|e| ::temporalio_sdk::WorkflowTermination::from(::anyhow::Error::new(e))),
1015+
.map_err(::temporalio_sdk::WorkflowTermination::from),
10161016
Err(e) => Err(e),
10171017
}
10181018
}.boxed_local()

crates/sdk/src/lib.rs

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1281,6 +1281,15 @@ impl From<temporalio_common::data_converters::PayloadConversionError> for Workfl
12811281
}
12821282
}
12831283

1284+
impl From<workflows::WorkflowError> for WorkflowTermination {
1285+
fn from(err: workflows::WorkflowError) -> Self {
1286+
match err {
1287+
workflows::WorkflowError::PayloadConversion(e) => Self::from(e),
1288+
workflows::WorkflowError::Execution(e) => Self::from(e),
1289+
}
1290+
}
1291+
}
1292+
12841293
impl From<ActivityExecutionError> for WorkflowTermination {
12851294
fn from(value: ActivityExecutionError) -> Self {
12861295
Self::Failed(value.into())

0 commit comments

Comments
 (0)