Skip to content

Commit 876a703

Browse files
committed
Fix mypy errors
1 parent d2fc47f commit 876a703

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

tests/worker/test_workflow.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -5660,10 +5660,10 @@ async def _run_workflow_and_get_warning(self) -> bool:
56605660
elif self.handler_waiting == "-wait-all-handlers-finish-":
56615661
await update_task
56625662
else:
5663-
with pytest.raises(RPCError) as update_err:
5663+
with pytest.raises(RPCError) as rpc_err:
56645664
await update_task
5665-
assert update_err.value.status == RPCStatusCode.NOT_FOUND and (
5666-
str(update_err.value).lower()
5665+
assert rpc_err.value.status == RPCStatusCode.NOT_FOUND and (
5666+
str(rpc_err.value).lower()
56675667
== "workflow execution already completed"
56685668
)
56695669

@@ -6165,11 +6165,11 @@ def __init__(self) -> None:
61656165
self.non_terminating_operation_has_started = False
61666166

61676167
@workflow.run
6168-
async def run(self) -> NoReturn:
6168+
async def run(self) -> None:
61696169
await asyncio.Future()
61706170

61716171
@workflow.update(unfinished_policy=workflow.HandlerUnfinishedPolicy.ABANDON)
6172-
async def non_terminating_update(self) -> NoReturn:
6172+
async def non_terminating_update(self) -> None:
61736173
self.non_terminating_operation_has_started = True
61746174
await asyncio.Future()
61756175

@@ -6198,4 +6198,4 @@ async def test_update_cancellation(client: Client):
61986198
# Cancel the workflow and confirm that update caller sees update failed
61996199
await wf_handle.cancel()
62006200
with pytest.raises(WorkflowUpdateFailedError):
6201-
await non_terminating_update
6201+
await non_terminating_update # type: ignore

0 commit comments

Comments
 (0)