Skip to content

Commit 94fa0be

Browse files
fix lints
1 parent 559c526 commit 94fa0be

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

crates/sdk-core/tests/integ_tests/workflow_tests/activities.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ use temporalio_common::{
3939
temporal::api::{
4040
common::v1::{ActivityType, Payload, Payloads, RetryPolicy},
4141
enums::v1::{
42-
ApplicationErrorCategory, CommandType, EventType, RetryState, TimeoutType,
42+
CommandType, EventType, RetryState, TimeoutType,
4343
},
4444
failure::v1::{ActivityFailureInfo, Failure, failure::FailureInfo},
4545
sdk::v1::UserMetadata,

crates/sdk/src/lib.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -618,13 +618,13 @@ impl Worker {
618618
}| {
619619
let wf_half = &*wf_half;
620620
async move {
621-
let result = join_handle.await.map_err(|e| anyhow::anyhow!("{e}"))?;
621+
let result = join_handle.await.map_err(anyhow::Error::new)?;
622622
// Eviction is normal workflow lifecycle - workflows loop waiting for
623623
// eviction after completion to manage cache cleanup
624624
if let Err(e) = result
625625
&& !matches!(e, WorkflowTermination::Evicted)
626626
{
627-
return Err(anyhow::anyhow!("{e}"));
627+
return Err(anyhow::Error::new(e));
628628
}
629629
debug!(run_id=%run_id, "Removing workflow from cache");
630630
wf_half.workflows.borrow_mut().remove(&run_id);

0 commit comments

Comments
 (0)