This issue tracker has been migrated to GitHub, and is currently read-only.
For more information, see the GitHub FAQs in the Python's Developer Guide.

classification
Title: asyncio.wait_for: process future result produced during cancelation
Type: enhancement Stage:
Components: asyncio Versions: Python 3.9
process
Status: open Resolution:
Dependencies: Superseder:
Assigned To: Nosy List: Roman Skurikhin, asvetlov, chris.jerdonek, yselivanov
Priority: normal Keywords:

Created on 2020-05-18 17:23 by Roman Skurikhin, last changed 2022-04-11 14:59 by admin.

Messages (3)
msg369278 - (view) Author: Roman Skurikhin (Roman Skurikhin) * Date: 2020-05-18 17:23
In https://bugs.python.org/issue40607 asyncio.wait_for behavior was changed so it propagates exceptions that happened during cancellation. But it still raises `TimeoutError` if cancelation ends with some value being returned. In the following example value `42` is lost:

import asyncio


async def return_42_on_cancel():
    try:
        await asyncio.sleep(20)
    except asyncio.CancelledError:
        return 42  # `return` is useless in this block.


async def main():
    try:
        await asyncio.wait_for(return_42_on_cancel(), timeout=1)
    except asyncio.TimeoutError:
        print('Timeout')

asyncio.run(main())


I think it's better to either:

1) Return that value from `asyncio.wait_for`.

The motivation here is that if the task returns something, we shouldn't conceal it. I also searched through GitHub and found some places where others catch `CancelledError` and return value (https://github.com/grpc/grpc/blob/44fb37c99f2853cc23f04fba15468980d9e28e41/src/python/grpcio/grpc/experimental/aio/_interceptor.py#L328).

It can also be used with some coroutines developed to be wrapped with `wait_for`, for example suppose the following equation solving function:

async def solve_iteratively(initial_x, next_approximation):
    result = initial_x
    try:
        while True:
            result = next_approximation(result)
            await asyncio.sleep(0)
    except asyncio.CancelledError:
        return result

It allows us to control its execution time using asyncio.wait_for.


2) Add some warning about the value is thrown away (in debug mode) and document it somewhere.

===

I am a newbie here, so sorry if it is wrong to create such "proposal" issues.
msg369285 - (view) Author: Yury Selivanov (yselivanov) * (Python committer) Date: 2020-05-18 18:34
> 2) Add some warning about the value is thrown away (in debug mode) and document it somewhere.

The documentation update is definitely something that needs to be done in 3.9.  Want to submit a PR?

We can also issue a warning in asyncio debug mode.

I'm really not sure about "1) Return that value from `asyncio.wait_for`.".


> I am a newbie here, so sorry if it is wrong to create such "proposal" issues.

The issue is clear, thanks for submitting it! Keep up the great work.
msg369308 - (view) Author: Chris Jerdonek (chris.jerdonek) * (Python committer) Date: 2020-05-18 22:51
Regarding the documentation, I'm not sure we _need_ to say what happens in this edge case for 3.9. It was already unspecified before 3.9, so we're not any worse off. (The change in issue 40607 was, however, documented.)

I'd rather come to agreement on (1) first. Because if we document it now, then it could be interpreted as defined behavior and so harder to change later due to backwards compat guarantees.
History
Date User Action Args
2022-04-11 14:59:31adminsetgithub: 84849
2020-05-18 22:51:20chris.jerdoneksetmessages: + msg369308
2020-05-18 18:34:00yselivanovsetnosy: + chris.jerdonek
messages: + msg369285
2020-05-18 17:23:20Roman Skurikhincreate