File tree 1 file changed +2
-2
lines changed
message_passing/waiting_for_handlers_and_compensation
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -32,7 +32,7 @@ def __init__(self) -> None:
32
32
# "race" this future against a task performing the message handler's own
33
33
# application logic; if this future completes before the message handler
34
34
# task then the handler should abort and perform compensation.
35
- self .workflow_exit = asyncio .Future ()
35
+ self .workflow_exit : asyncio . Future [ None ] = asyncio .Future ()
36
36
self ._update_compensation_done = False
37
37
38
38
@workflow .run
@@ -82,7 +82,7 @@ async def my_update(self) -> str:
82
82
# 👉 "Race" the workflow_exit future against the handler's own application
83
83
# logic. Always use `workflow.wait` instead of `asyncio.wait` in
84
84
# Workflow code: asyncio's version is non-deterministic.
85
- await workflow .wait (
85
+ await workflow .wait ( # type: ignore
86
86
[update_task , self .workflow_exit ], return_when = asyncio .FIRST_EXCEPTION
87
87
)
88
88
try :
You can’t perform that action at this time.
0 commit comments