chore: remove unnecessary anyhow wrapping from tests

chris-olszewski · chris-olszewski · commit 907e6d99c9b7 · 2026-05-01T12:31:57.000-04:00
diff --git a/crates/sdk-core/tests/integ_tests/data_converter_tests.rs b/crates/sdk-core/tests/integ_tests/data_converter_tests.rs
@@ -194,8 +194,7 @@ impl DataConverterTestWorkflow {
                 input,
                 ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),
             )
-            .await
-            .map_err(|e| anyhow::anyhow!("{e}"))?;
+            .await?;
 
         Ok(output)
     }
@@ -218,8 +217,7 @@ impl DescribeDataConverterWorkflow {
                 input,
                 ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),
             )
-            .await
-            .map_err(|e| anyhow::anyhow!("{e}"))?;
+            .await?;
 
         Ok(output)
     }
diff --git a/crates/sdk-core/tests/integ_tests/worker_tests.rs b/crates/sdk-core/tests/integ_tests/worker_tests.rs
@@ -419,15 +419,13 @@ async fn activity_tasks_from_completion_reserve_slots() {
                 (),
                 ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),
             )
-            .await
-            .map_err(|e| WorkflowTermination::from(anyhow::Error::from(e)))?;
+            .await?;
             ctx.start_activity(
                 FakeAct::act2,
                 (),
                 ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),
             )
-            .await
-            .map_err(|e| WorkflowTermination::from(anyhow::Error::from(e)))?;
+            .await?;
             ctx.state(|wf| wf.complete_token.cancel());
             Ok(())
         }
diff --git a/crates/sdk-core/tests/integ_tests/workflow_tests.rs b/crates/sdk-core/tests/integ_tests/workflow_tests.rs
@@ -505,8 +505,7 @@ impl SlowCompletesWf {
                 "hi!".to_string(),
                 ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),
             )
-            .await
-            .map_err(|e| anyhow::anyhow!("{e}"))?;
+            .await?;
             ctx.timer(Duration::from_secs(1)).await;
         }
         Ok(())
@@ -881,8 +880,7 @@ async fn nondeterminism_errors_fail_workflow_when_configured_to(
                 "hi".to_owned(),
                 ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),
             )
-            .await
-            .map_err(|e| anyhow::anyhow!("{e}"))?;
+            .await?;
             Ok(())
         }
     }
@@ -956,15 +954,13 @@ async fn history_out_of_order_on_restart() {
                     ..Default::default()
                 },
             )
-            .await
-            .map_err(|e| anyhow::anyhow!("{e}"))?;
+            .await?;
             ctx.start_activity(
                 StdActivities::echo,
                 "hi".to_string(),
                 ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),
             )
-            .await
-            .map_err(|e| anyhow::anyhow!("{e}"))?;
+            .await?;
             ctx.state(|wf| wf.hit_sleep.notify_one());
             ctx.timer(Duration::from_secs(5)).await;
             Ok(())
@@ -987,17 +983,15 @@ async fn history_out_of_order_on_restart() {
                     ..Default::default()
                 },
             )
-            .await
-            .map_err(|e| anyhow::anyhow!("{e}"))?;
+            .await?;
             // Timer is added after restarting workflow
             ctx.timer(Duration::from_secs(1)).await;
             ctx.start_activity(
                 StdActivities::echo,
                 "hi".to_string(),
                 ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),
             )
-            .await
-            .map_err(|e| anyhow::anyhow!("{e}"))?;
+            .await?;
             ctx.timer(Duration::from_secs(2)).await;
             Ok(())
         }
diff --git a/crates/sdk-core/tests/integ_tests/workflow_tests/activities.rs b/crates/sdk-core/tests/integ_tests/workflow_tests/activities.rs
@@ -72,8 +72,7 @@ impl OneActivityWorkflow {
                 input,
                 ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),
             )
-            .await
-            .map_err(|e| anyhow!("{e}"))?;
+            .await?;
         Ok(r)
     }
 }
@@ -92,8 +91,7 @@ impl MultiArgActivityWorkflow {
                 (input, " world".to_string()),
                 ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),
             )
-            .await
-            .map_err(|e| anyhow!("{e}"))?;
+            .await?;
         Ok(r)
     }
 }
@@ -172,18 +170,19 @@ async fn activity_panics_are_retryable() {
     impl ActivityPanicRetryWorkflow {
         #[run]
         async fn run(ctx: &mut WorkflowContext<Self>) -> WorkflowResult<u32> {
-            ctx.start_activity(
-                PanicOnceActivities::panic_once,
-                (),
-                ActivityOptions::with_start_to_close_timeout(Duration::from_secs(5))
-                    .retry_policy(RetryPolicy {
-                        maximum_attempts: 2,
-                        ..Default::default()
-                    })
-                    .build(),
-            )
-            .await
-            .map_err(|e| anyhow!("{e}").into())
+            let result = ctx
+                .start_activity(
+                    PanicOnceActivities::panic_once,
+                    (),
+                    ActivityOptions::with_start_to_close_timeout(Duration::from_secs(5))
+                        .retry_policy(RetryPolicy {
+                            maximum_attempts: 2,
+                            ..Default::default()
+                        })
+                        .build(),
+                )
+                .await?;
+            Ok(result)
         }
     }
 
diff --git a/crates/sdk-core/tests/integ_tests/workflow_tests/child_workflows.rs b/crates/sdk-core/tests/integ_tests/workflow_tests/child_workflows.rs
@@ -93,7 +93,8 @@ impl HappyParent {
             )
             .await
             .expect("Child should start OK");
-        started.result().await.map_err(|e| anyhow!(e).into())
+        started.result().await?;
+        Ok(())
     }
 }
 
@@ -811,8 +812,7 @@ impl PassChildWorkflowSummaryToMetadata {
                 ..Default::default()
             },
         )
-        .await
-        .map_err(|e| anyhow!(e))?;
+        .await?;
         Ok(())
     }
 }
@@ -920,7 +920,7 @@ impl ParentWf {
                 _ => return Err(anyhow!("Expected start failure").into()),
             }
         }
-        let started = start_res.map_err(|e| anyhow!(e))?;
+        let started = start_res?;
         match (expectation, started.result().await) {
             (Expectation::Success, Ok(_)) => Ok(()),
             (Expectation::Failure, Err(ChildWorkflowExecutionError::Failed(failure))) => {
@@ -1274,13 +1274,9 @@ impl UntypedHappyParent {
                     ..Default::default()
                 },
             )
-            .await
-            .map_err(|e| anyhow!(e))?;
-        started
-            .result()
-            .await
-            .map(|_| ())
-            .map_err(|e| anyhow!(e).into())
+            .await?;
+        started.result().await?;
+        Ok(())
     }
 }
 
@@ -1416,8 +1412,7 @@ impl ChildSignalSerializationFailParent {
                     ..Default::default()
                 },
             )
-            .await
-            .map_err(|e| anyhow!(e))?;
+            .await?;
 
         let signal_result = started
             .signal(UnserializableSignalChild::bad_signal, AlwaysFailsSerialize)
@@ -1484,8 +1479,7 @@ impl UnitChildParentWf {
                     ..Default::default()
                 },
             )
-            .await
-            .map_err(|e| anyhow!(e))?;
+            .await?;
         started.result().await?;
         Ok(())
     }
diff --git a/crates/sdk-core/tests/integ_tests/workflow_tests/determinism.rs b/crates/sdk-core/tests/integ_tests/workflow_tests/determinism.rs
@@ -57,8 +57,7 @@ impl TimerWfNondeterministic {
                     (),
                     ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),
                 )
-                .await
-                .map_err(|e| anyhow::anyhow!("{e}"))?;
+                .await?;
             }
             _ => panic!("Ran too many times"),
         }
@@ -290,12 +289,10 @@ impl ActivityIdOrTypeChangeWf {
                         ..Default::default()
                     },
                 )
-                .await
-                .map_err(|e| anyhow::anyhow!("{e}"))?;
+                .await?;
             } else {
                 ctx.start_local_activity(StdActivities::no_op, (), Default::default())
-                    .await
-                    .map_err(|e| anyhow::anyhow!("{e}"))?;
+                    .await?;
             }
         } else if id_change {
             ctx.start_activity(
@@ -305,16 +302,14 @@ impl ActivityIdOrTypeChangeWf {
                     .activity_id("I'm bad and wrong!".to_string())
                     .build(),
             )
-            .await
-            .map_err(|e| anyhow::anyhow!("{e}"))?;
+            .await?;
         } else {
             ctx.start_activity(
                 StdActivities::no_op,
                 (),
                 ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),
             )
-            .await
-            .map_err(|e| anyhow::anyhow!("{e}"))?;
+            .await?;
         }
         Ok(())
     }
diff --git a/crates/sdk-core/tests/integ_tests/workflow_tests/local_activities.rs b/crates/sdk-core/tests/integ_tests/workflow_tests/local_activities.rs
@@ -81,8 +81,7 @@ impl OneLocalActivityWf {
             "hi!".to_string(),
             LocalActivityOptions::default(),
         )
-        .await
-        .map_err(|e| WorkflowTermination::from(anyhow::Error::from(e)))?;
+        .await?;
         assert!(initial_workflow_time < ctx.workflow_time().unwrap());
         Ok(())
     }
@@ -1128,8 +1127,7 @@ async fn long_local_activity_with_update(
                 Duration::from_secs(6),
                 LocalActivityOptions::default(),
             )
-            .await
-            .map_err(|e| WorkflowTermination::from(anyhow::Error::from(e)))?;
+            .await?;
             Ok(ctx.state(|wf| wf.update_counter))
         }
 
@@ -1273,8 +1271,7 @@ impl LocalActivityWithSummaryWf {
                 ..Default::default()
             },
         )
-        .await
-        .map_err(|e| WorkflowTermination::from(anyhow::Error::from(e)))?;
+        .await?;
         Ok(())
     }
 }
@@ -1440,8 +1437,7 @@ async fn local_act_heartbeat(#[case] shutdown_middle: bool) {
                 "hi".to_string(),
                 LocalActivityOptions::default(),
             )
-            .await
-            .map_err(|e| WorkflowTermination::from(anyhow::Error::from(e)))?;
+            .await?;
             Ok(())
         }
     }
@@ -1662,8 +1658,7 @@ async fn local_act_null_result() {
         #[run(name = DEFAULT_WORKFLOW_TYPE)]
         async fn run(ctx: &mut WorkflowContext<Self>) -> WorkflowResult<()> {
             ctx.start_local_activity(StdActivities::default, (), LocalActivityOptions::default())
-                .await
-                .map_err(|e| WorkflowTermination::from(anyhow::Error::from(e)))?;
+                .await?;
             Ok(())
         }
     }
@@ -1699,8 +1694,7 @@ async fn local_act_command_immediately_follows_la_marker() {
         #[run(name = DEFAULT_WORKFLOW_TYPE)]
         async fn run(ctx: &mut WorkflowContext<Self>) -> WorkflowResult<()> {
             ctx.start_local_activity(StdActivities::default, (), LocalActivityOptions::default())
-                .await
-                .map_err(|e| WorkflowTermination::from(anyhow::Error::from(e)))?;
+                .await?;
             ctx.timer(Duration::from_secs(1)).await;
             Ok(())
         }
@@ -2319,8 +2313,7 @@ async fn resolved_las_not_recorded_if_wft_fails_many_times() {
                     ..Default::default()
                 },
             )
-            .await
-            .map_err(|e| WorkflowTermination::from(anyhow::Error::from(e)))?;
+            .await?;
             panic!()
         }
     }
@@ -2870,11 +2863,9 @@ impl TwoLaWf {
     #[run(name = DEFAULT_WORKFLOW_TYPE)]
     async fn run(ctx: &mut WorkflowContext<Self>) -> WorkflowResult<()> {
         ctx.start_local_activity(StdActivities::default, (), LocalActivityOptions::default())
-            .await
-            .map_err(|e| WorkflowTermination::from(anyhow::Error::from(e)))?;
+            .await?;
         ctx.start_local_activity(StdActivities::default, (), LocalActivityOptions::default())
-            .await
-            .map_err(|e| WorkflowTermination::from(anyhow::Error::from(e)))?;
+            .await?;
         Ok(())
     }
 }
@@ -3007,12 +2998,10 @@ impl LaTimerLaWf {
     #[run(name = DEFAULT_WORKFLOW_TYPE)]
     async fn run(ctx: &mut WorkflowContext<Self>) -> WorkflowResult<()> {
         ctx.start_local_activity(StdActivities::default, (), LocalActivityOptions::default())
-            .await
-            .map_err(|e| WorkflowTermination::from(anyhow::Error::from(e)))?;
+            .await?;
         ctx.timer(Duration::from_secs(5)).await;
         ctx.start_local_activity(StdActivities::default, (), LocalActivityOptions::default())
-            .await
-            .map_err(|e| WorkflowTermination::from(anyhow::Error::from(e)))?;
+            .await?;
         Ok(())
     }
 }
diff --git a/crates/sdk-core/tests/integ_tests/workflow_tests/resets.rs b/crates/sdk-core/tests/integ_tests/workflow_tests/resets.rs
@@ -152,8 +152,7 @@ impl ResetRandomseedWf {
                 "hi!".to_string(),
                 LocalActivityOptions::default(),
             )
-            .await
-            .map_err(|e| anyhow::anyhow!("{e}"))?;
+            .await?;
         }
         ctx.wait_condition(|s| s.post_fail_received).await;
         ctx.state(|wf| wf.notify.notify_one());

Original file line number	Diff line number	Diff line change
`@@ -194,8 +194,7 @@ impl DataConverterTestWorkflow {`
`194`	`194`	`input,`
`195`	`195`	`ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),`
`196`	`196`	`)`
`197`		`- .await`
`198`		`- .map_err(\|e\| anyhow::anyhow!("{e}"))?;`
	`197`	`+ .await?;`
`199`	`198`
`200`	`199`	`Ok(output)`
`201`	`200`	`}`
`@@ -218,8 +217,7 @@ impl DescribeDataConverterWorkflow {`
`218`	`217`	`input,`
`219`	`218`	`ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),`
`220`	`219`	`)`
`221`		`- .await`
`222`		`- .map_err(\|e\| anyhow::anyhow!("{e}"))?;`
	`220`	`+ .await?;`
`223`	`221`
`224`	`222`	`Ok(output)`
`225`	`223`	`}`
Original file line number	Diff line number	Diff line change
`@@ -419,15 +419,13 @@ async fn activity_tasks_from_completion_reserve_slots() {`
`419`	`419`	`(),`
`420`	`420`	`ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),`
`421`	`421`	`)`
`422`		`- .await`
`423`		`- .map_err(\|e\| WorkflowTermination::from(anyhow::Error::from(e)))?;`
	`422`	`+ .await?;`
`424`	`423`	`ctx.start_activity(`
`425`	`424`	`FakeAct::act2,`
`426`	`425`	`(),`
`427`	`426`	`ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),`
`428`	`427`	`)`
`429`		`- .await`
`430`		`- .map_err(\|e\| WorkflowTermination::from(anyhow::Error::from(e)))?;`
	`428`	`+ .await?;`
`431`	`429`	`ctx.state(\|wf\| wf.complete_token.cancel());`
`432`	`430`	`Ok(())`
`433`	`431`	`}`
Original file line number	Diff line number	Diff line change
`@@ -93,7 +93,8 @@ impl HappyParent {`
`93`	`93`	`)`
`94`	`94`	`.await`
`95`	`95`	`.expect("Child should start OK");`
`96`		`- started.result().await.map_err(\|e\| anyhow!(e).into())`
	`96`	`+ started.result().await?;`
	`97`	`+ Ok(())`
`97`	`98`	`}`
`98`	`99`	`}`
`99`	`100`
`@@ -811,8 +812,7 @@ impl PassChildWorkflowSummaryToMetadata {`
`811`	`812`	`..Default::default()`
`812`	`813`	`},`
`813`	`814`	`)`
`814`		`- .await`
`815`		`- .map_err(\|e\| anyhow!(e))?;`
	`815`	`+ .await?;`
`816`	`816`	`Ok(())`
`817`	`817`	`}`
`818`	`818`	`}`
`@@ -920,7 +920,7 @@ impl ParentWf {`
`920`	`920`	`_ => return Err(anyhow!("Expected start failure").into()),`
`921`	`921`	`}`
`922`	`922`	`}`
`923`		`- let started = start_res.map_err(\|e\| anyhow!(e))?;`
	`923`	`+ let started = start_res?;`
`924`	`924`	`match (expectation, started.result().await) {`
`925`	`925`	`(Expectation::Success, Ok(_)) => Ok(()),`
`926`	`926`	`(Expectation::Failure, Err(ChildWorkflowExecutionError::Failed(failure))) => {`
`@@ -1274,13 +1274,9 @@ impl UntypedHappyParent {`
`1274`	`1274`	`..Default::default()`
`1275`	`1275`	`},`
`1276`	`1276`	`)`
`1277`		`- .await`
`1278`		`- .map_err(\|e\| anyhow!(e))?;`
`1279`		`- started`
`1280`		`- .result()`
`1281`		`- .await`
`1282`		`- .map(\|_\| ())`
`1283`		`- .map_err(\|e\| anyhow!(e).into())`
	`1277`	`+ .await?;`
	`1278`	`+ started.result().await?;`
	`1279`	`+ Ok(())`
`1284`	`1280`	`}`
`1285`	`1281`	`}`
`1286`	`1282`
`@@ -1416,8 +1412,7 @@ impl ChildSignalSerializationFailParent {`
`1416`	`1412`	`..Default::default()`
`1417`	`1413`	`},`
`1418`	`1414`	`)`
`1419`		`- .await`
`1420`		`- .map_err(\|e\| anyhow!(e))?;`
	`1415`	`+ .await?;`
`1421`	`1416`
`1422`	`1417`	`let signal_result = started`
`1423`	`1418`	`.signal(UnserializableSignalChild::bad_signal, AlwaysFailsSerialize)`
`@@ -1484,8 +1479,7 @@ impl UnitChildParentWf {`
`1484`	`1479`	`..Default::default()`
`1485`	`1480`	`},`
`1486`	`1481`	`)`
`1487`		`- .await`
`1488`		`- .map_err(\|e\| anyhow!(e))?;`
	`1482`	`+ .await?;`
`1489`	`1483`	`started.result().await?;`
`1490`	`1484`	`Ok(())`
`1491`	`1485`	`}`
Original file line number	Diff line number	Diff line change
`@@ -57,8 +57,7 @@ impl TimerWfNondeterministic {`
`57`	`57`	`(),`
`58`	`58`	`ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),`
`59`	`59`	`)`
`60`		`- .await`
`61`		`- .map_err(\|e\| anyhow::anyhow!("{e}"))?;`
	`60`	`+ .await?;`
`62`	`61`	`}`
`63`	`62`	`_ => panic!("Ran too many times"),`
`64`	`63`	`}`
`@@ -290,12 +289,10 @@ impl ActivityIdOrTypeChangeWf {`
`290`	`289`	`..Default::default()`
`291`	`290`	`},`
`292`	`291`	`)`
`293`		`- .await`
`294`		`- .map_err(\|e\| anyhow::anyhow!("{e}"))?;`
	`292`	`+ .await?;`
`295`	`293`	`} else {`
`296`	`294`	`ctx.start_local_activity(StdActivities::no_op, (), Default::default())`
`297`		`- .await`
`298`		`- .map_err(\|e\| anyhow::anyhow!("{e}"))?;`
	`295`	`+ .await?;`
`299`	`296`	`}`
`300`	`297`	`} else if id_change {`
`301`	`298`	`ctx.start_activity(`
`@@ -305,16 +302,14 @@ impl ActivityIdOrTypeChangeWf {`
`305`	`302`	`.activity_id("I'm bad and wrong!".to_string())`
`306`	`303`	`.build(),`
`307`	`304`	`)`
`308`		`- .await`
`309`		`- .map_err(\|e\| anyhow::anyhow!("{e}"))?;`
	`305`	`+ .await?;`
`310`	`306`	`} else {`
`311`	`307`	`ctx.start_activity(`
`312`	`308`	`StdActivities::no_op,`
`313`	`309`	`(),`
`314`	`310`	`ActivityOptions::start_to_close_timeout(Duration::from_secs(5)),`
`315`	`311`	`)`
`316`		`- .await`
`317`		`- .map_err(\|e\| anyhow::anyhow!("{e}"))?;`
	`312`	`+ .await?;`
`318`	`313`	`}`
`319`	`314`	`Ok(())`
`320`	`315`	`}`
Original file line number	Diff line number	Diff line change
`@@ -81,8 +81,7 @@ impl OneLocalActivityWf {`
`81`	`81`	`"hi!".to_string(),`
`82`	`82`	`LocalActivityOptions::default(),`
`83`	`83`	`)`
`84`		`- .await`
`85`		`- .map_err(\|e\| WorkflowTermination::from(anyhow::Error::from(e)))?;`
	`84`	`+ .await?;`
`86`	`85`	`assert!(initial_workflow_time < ctx.workflow_time().unwrap());`
`87`	`86`	`Ok(())`
`88`	`87`	`}`
`@@ -1128,8 +1127,7 @@ async fn long_local_activity_with_update(`
`1128`	`1127`	`Duration::from_secs(6),`
`1129`	`1128`	`LocalActivityOptions::default(),`
`1130`	`1129`	`)`
`1131`		`- .await`
`1132`		`- .map_err(\|e\| WorkflowTermination::from(anyhow::Error::from(e)))?;`
	`1130`	`+ .await?;`
`1133`	`1131`	`Ok(ctx.state(\|wf\| wf.update_counter))`
`1134`	`1132`	`}`
`1135`	`1133`
`@@ -1273,8 +1271,7 @@ impl LocalActivityWithSummaryWf {`
`1273`	`1271`	`..Default::default()`
`1274`	`1272`	`},`
`1275`	`1273`	`)`
`1276`		`- .await`
`1277`		`- .map_err(\|e\| WorkflowTermination::from(anyhow::Error::from(e)))?;`
	`1274`	`+ .await?;`
`1278`	`1275`	`Ok(())`
`1279`	`1276`	`}`
`1280`	`1277`	`}`
`@@ -1440,8 +1437,7 @@ async fn local_act_heartbeat(#[case] shutdown_middle: bool) {`
`1440`	`1437`	`"hi".to_string(),`
`1441`	`1438`	`LocalActivityOptions::default(),`
`1442`	`1439`	`)`
`1443`		`- .await`
`1444`		`- .map_err(\|e\| WorkflowTermination::from(anyhow::Error::from(e)))?;`
	`1440`	`+ .await?;`
`1445`	`1441`	`Ok(())`
`1446`	`1442`	`}`
`1447`	`1443`	`}`
`@@ -1662,8 +1658,7 @@ async fn local_act_null_result() {`
`1662`	`1658`	`#[run(name = DEFAULT_WORKFLOW_TYPE)]`
`1663`	`1659`	`async fn run(ctx: &mut WorkflowContext<Self>) -> WorkflowResult<()> {`
`1664`	`1660`	`ctx.start_local_activity(StdActivities::default, (), LocalActivityOptions::default())`
`1665`		`- .await`
`1666`		`- .map_err(\|e\| WorkflowTermination::from(anyhow::Error::from(e)))?;`
	`1661`	`+ .await?;`
`1667`	`1662`	`Ok(())`
`1668`	`1663`	`}`
`1669`	`1664`	`}`
`@@ -1699,8 +1694,7 @@ async fn local_act_command_immediately_follows_la_marker() {`
`1699`	`1694`	`#[run(name = DEFAULT_WORKFLOW_TYPE)]`
`1700`	`1695`	`async fn run(ctx: &mut WorkflowContext<Self>) -> WorkflowResult<()> {`
`1701`	`1696`	`ctx.start_local_activity(StdActivities::default, (), LocalActivityOptions::default())`
`1702`		`- .await`
`1703`		`- .map_err(\|e\| WorkflowTermination::from(anyhow::Error::from(e)))?;`
	`1697`	`+ .await?;`
`1704`	`1698`	`ctx.timer(Duration::from_secs(1)).await;`
`1705`	`1699`	`Ok(())`
`1706`	`1700`	`}`
`@@ -2319,8 +2313,7 @@ async fn resolved_las_not_recorded_if_wft_fails_many_times() {`
`2319`	`2313`	`..Default::default()`
`2320`	`2314`	`},`
`2321`	`2315`	`)`
`2322`		`- .await`
`2323`		`- .map_err(\|e\| WorkflowTermination::from(anyhow::Error::from(e)))?;`
	`2316`	`+ .await?;`
`2324`	`2317`	`panic!()`
`2325`	`2318`	`}`
`2326`	`2319`	`}`
`@@ -2870,11 +2863,9 @@ impl TwoLaWf {`
`2870`	`2863`	`#[run(name = DEFAULT_WORKFLOW_TYPE)]`
`2871`	`2864`	`async fn run(ctx: &mut WorkflowContext<Self>) -> WorkflowResult<()> {`
`2872`	`2865`	`ctx.start_local_activity(StdActivities::default, (), LocalActivityOptions::default())`
`2873`		`- .await`
`2874`		`- .map_err(\|e\| WorkflowTermination::from(anyhow::Error::from(e)))?;`
	`2866`	`+ .await?;`
`2875`	`2867`	`ctx.start_local_activity(StdActivities::default, (), LocalActivityOptions::default())`
`2876`		`- .await`
`2877`		`- .map_err(\|e\| WorkflowTermination::from(anyhow::Error::from(e)))?;`
	`2868`	`+ .await?;`
`2878`	`2869`	`Ok(())`
`2879`	`2870`	`}`
`2880`	`2871`	`}`
`@@ -3007,12 +2998,10 @@ impl LaTimerLaWf {`
`3007`	`2998`	`#[run(name = DEFAULT_WORKFLOW_TYPE)]`
`3008`	`2999`	`async fn run(ctx: &mut WorkflowContext<Self>) -> WorkflowResult<()> {`
`3009`	`3000`	`ctx.start_local_activity(StdActivities::default, (), LocalActivityOptions::default())`
`3010`		`- .await`
`3011`		`- .map_err(\|e\| WorkflowTermination::from(anyhow::Error::from(e)))?;`
	`3001`	`+ .await?;`
`3012`	`3002`	`ctx.timer(Duration::from_secs(5)).await;`
`3013`	`3003`	`ctx.start_local_activity(StdActivities::default, (), LocalActivityOptions::default())`
`3014`		`- .await`
`3015`		`- .map_err(\|e\| WorkflowTermination::from(anyhow::Error::from(e)))?;`
	`3004`	`+ .await?;`
`3016`	`3005`	`Ok(())`
`3017`	`3006`	`}`
`3018`	`3007`	`}`
Original file line number	Diff line number	Diff line change
`@@ -152,8 +152,7 @@ impl ResetRandomseedWf {`
`152`	`152`	`"hi!".to_string(),`
`153`	`153`	`LocalActivityOptions::default(),`
`154`	`154`	`)`
`155`		`- .await`
`156`		`- .map_err(\|e\| anyhow::anyhow!("{e}"))?;`
	`155`	`+ .await?;`
`157`	`156`	`}`
`158`	`157`	`ctx.wait_condition(\|s\| s.post_fail_received).await;`
`159`	`158`	`ctx.state(\|wf\| wf.notify.notify_one());`