diff options
| author | shadchin <shadchin@yandex-team.com> | 2024-02-07 09:25:06 +0300 |
|---|---|---|
| committer | shadchin <shadchin@yandex-team.com> | 2024-02-07 09:40:03 +0300 |
| commit | 3139d9ab6df2a7014d19b87582466d17b4f496e2 (patch) | |
| tree | 7fcb26a72dac212aa26beaaa7cd769fb1e396b5e /contrib/tools/python3/src/Lib/asyncio/streams.py | |
| parent | 4c04a8d1e278e6ca7ff16c11b74b2f16fc144253 (diff) | |
| download | ydb-3139d9ab6df2a7014d19b87582466d17b4f496e2.tar.gz | |
Update Python 3 to 3.11.8
Diffstat (limited to 'contrib/tools/python3/src/Lib/asyncio/streams.py')
| -rw-r--r-- | contrib/tools/python3/src/Lib/asyncio/streams.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/contrib/tools/python3/src/Lib/asyncio/streams.py b/contrib/tools/python3/src/Lib/asyncio/streams.py index 23b6e4c32f..26ffc86584 100644 --- a/contrib/tools/python3/src/Lib/asyncio/streams.py +++ b/contrib/tools/python3/src/Lib/asyncio/streams.py @@ -246,6 +246,9 @@ class StreamReaderProtocol(FlowControlMixin, protocols.Protocol): self._stream_writer) if coroutines.iscoroutine(res): def callback(task): + if task.cancelled(): + transport.close() + return exc = task.exception() if exc is not None: self._loop.call_exception_handler({ |