We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a02f3a7 commit 535b0b9Copy full SHA for 535b0b9
packages/service-library/src/servicelib/deferred_tasks/_worker_tracker.py
@@ -57,6 +57,7 @@ async def handle_run(
57
result_to_return = TaskResultSuccess(value=task_result)
58
except asyncio.CancelledError:
59
result_to_return = TaskResultCancelledError()
60
+ # NOTE: if the task is itself cancelled it shall re-raise: see https://superfastpython.com/asyncio-cancellederror-consumed/
61
current_task = asyncio.current_task()
62
assert current_task is not None # nosec
63
if current_task.cancelling() > 0:
0 commit comments