Skip to content

Commit f41283c

Browse files
authored
Fix linter violations (#651)
1 parent 193b087 commit f41283c

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

tests/integ_tests/workflow_tests/cancel_external.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ async fn cancel_sender(ctx: WfContext) -> WorkflowResult<()> {
2525
Ok(().into())
2626
}
2727

28-
async fn cancel_receiver(mut ctx: WfContext) -> WorkflowResult<()> {
28+
async fn cancel_receiver(ctx: WfContext) -> WorkflowResult<()> {
2929
ctx.cancelled().await;
3030
Ok(().into())
3131
}

tests/integ_tests/workflow_tests/cancel_wf.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ use temporal_sdk::{WfContext, WfExitValue, WorkflowResult};
44
use temporal_sdk_core_protos::temporal::api::enums::v1::WorkflowExecutionStatus;
55
use temporal_sdk_core_test_utils::CoreWfStarter;
66

7-
async fn cancelled_wf(mut ctx: WfContext) -> WorkflowResult<()> {
7+
async fn cancelled_wf(ctx: WfContext) -> WorkflowResult<()> {
88
let cancelled = tokio::select! {
99
_ = ctx.timer(Duration::from_secs(500)) => false,
1010
_ = ctx.cancelled() => true

tests/integ_tests/workflow_tests/child_workflows.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ async fn abandoned_child_bug_repro() {
6464

6565
worker.register_wf(
6666
PARENT_WF_TYPE.to_string(),
67-
move |mut ctx: WfContext| async move {
67+
move |ctx: WfContext| async move {
6868
let child = ctx.child_workflow(ChildWorkflowOptions {
6969
workflow_id: "abandoned-child".to_owned(),
7070
workflow_type: CHILD_WF_TYPE.to_owned(),
@@ -89,7 +89,7 @@ async fn abandoned_child_bug_repro() {
8989
Ok(().into())
9090
},
9191
);
92-
worker.register_wf(CHILD_WF_TYPE.to_string(), |mut ctx: WfContext| async move {
92+
worker.register_wf(CHILD_WF_TYPE.to_string(), |ctx: WfContext| async move {
9393
ctx.cancelled().await;
9494
Ok(WfExitValue::<()>::Cancelled)
9595
});
@@ -135,7 +135,7 @@ async fn abandoned_child_resolves_post_cancel() {
135135

136136
worker.register_wf(
137137
PARENT_WF_TYPE.to_string(),
138-
move |mut ctx: WfContext| async move {
138+
move |ctx: WfContext| async move {
139139
let child = ctx.child_workflow(ChildWorkflowOptions {
140140
workflow_id: "abandoned-child-resolve-post-cancel".to_owned(),
141141
workflow_type: CHILD_WF_TYPE.to_owned(),

0 commit comments

Comments
 (0)