]> granicus.if.org Git - python/commitdiff
bpo-30508: Don't log exceptions if Task/Future "cancel()" method was called. (#2110)
authorYury Selivanov <yury@magic.io>
Sun, 11 Jun 2017 14:11:47 +0000 (14:11 +0000)
committerGitHub <noreply@github.com>
Sun, 11 Jun 2017 14:11:47 +0000 (14:11 +0000)
Lib/asyncio/futures.py
Lib/asyncio/tasks.py
Lib/test/test_asyncio/test_futures.py
Lib/test/test_asyncio/test_tasks.py
Misc/NEWS

index 9ca8d8458bcf6248a54b286d5fd9b7fb719cb7d9..60b0d3133494c415e569d0a77e2d7547f65d50ad 100644 (file)
@@ -240,6 +240,7 @@ class Future:
         change the future's state to cancelled, schedule the callbacks and
         return True.
         """
+        self._log_traceback = False
         if self._state != _PENDING:
             return False
         self._state = _CANCELLED
index 89d0989c614a5636d52283e45b6965f338063406..6c43e6830a10f4b756e12aae2734dc0b675dbde0 100644 (file)
@@ -208,6 +208,7 @@ class Task(futures.Future):
         terminates with a CancelledError exception (even if cancel()
         was not called).
         """
+        self._log_traceback = False
         if self.done():
             return False
         if self._fut_waiter is not None:
index c306b77e653264ccd4253d7bf8c78cb86adf6ef6..195a006fe67e0ba51677ceaf4aa3d9bed71857c7 100644 (file)
@@ -314,6 +314,14 @@ class FutureTests(test_utils.TestCase):
         del fut
         self.assertFalse(m_log.error.called)
 
+    @mock.patch('asyncio.base_events.logger')
+    def test_tb_logger_not_called_after_cancel(self, m_log):
+        fut = asyncio.Future(loop=self.loop)
+        fut.set_exception(Exception())
+        fut.cancel()
+        del fut
+        self.assertFalse(m_log.error.called)
+
     @mock.patch('asyncio.base_events.logger')
     def test_tb_logger_result_unretrieved(self, m_log):
         fut = asyncio.Future(loop=self.loop)
index b3d0653e82e573e709899a98e4e6eb28311969f1..c419015a088b63e597ff19f2c17dbdf56f4a7cfa 100644 (file)
@@ -1828,6 +1828,25 @@ class TaskTests(test_utils.TestCase):
         })
         mock_handler.reset_mock()
 
+    @mock.patch('asyncio.base_events.logger')
+    def test_tb_logger_not_called_after_cancel(self, m_log):
+        loop = asyncio.new_event_loop()
+        self.set_event_loop(loop)
+
+        @asyncio.coroutine
+        def coro():
+            raise TypeError
+
+        @asyncio.coroutine
+        def runner():
+            task = loop.create_task(coro())
+            yield from asyncio.sleep(0.05, loop=loop)
+            task.cancel()
+            task = None
+
+        loop.run_until_complete(runner())
+        self.assertFalse(m_log.error.called)
+
     @mock.patch('asyncio.coroutines.logger')
     def test_coroutine_never_yielded(self, m_log):
         with set_coroutine_debug(True):
index 33b7b9ae9df8cf6a5b030f077b95887b14fe8525..e8f94451f8c5e89d23e20fc3af7e49980369c8b0 100644 (file)
--- a/Misc/NEWS
+++ b/Misc/NEWS
@@ -56,6 +56,9 @@ Extension Modules
 Library
 -------
 
+- bpo-30508: Don't log exceptions if Task/Future "cancel()" method was
+  called.
+
 - bpo-28556: Updates to typing module: Add generic AsyncContextManager, add
   support for ContextManager on all versions. Original PRs by Jelle Zijlstra
   and Ivan Levkivskyi