]> granicus.if.org Git - python/commitdiff
Issue #21163: Fix one more "Task was destroyed but it is pending!" log in tests
authorVictor Stinner <victor.stinner@gmail.com>
Wed, 25 Jun 2014 21:57:50 +0000 (23:57 +0200)
committerVictor Stinner <victor.stinner@gmail.com>
Wed, 25 Jun 2014 21:57:50 +0000 (23:57 +0200)
Lib/test/test_asyncio/test_tasks.py

index 4508987961768c3a024227140b39ccd271bd8cfb..b19d7ccc672a2b223bf0a9959a4da2ebc9a8ba25 100644 (file)
@@ -411,8 +411,10 @@ class TaskTests(test_utils.TestCase):
                     loop.stop()
 
         t = asyncio.Task(task(), loop=loop)
-        self.assertRaises(
-            RuntimeError, loop.run_until_complete, t)
+        with self.assertRaises(RuntimeError) as cm:
+            loop.run_until_complete(t)
+        self.assertEqual(str(cm.exception),
+                         'Event loop stopped before Future completed.')
         self.assertFalse(t.done())
         self.assertEqual(x, 2)
         self.assertAlmostEqual(0.3, loop.time())
@@ -420,6 +422,8 @@ class TaskTests(test_utils.TestCase):
         # close generators
         for w in waiters:
             w.close()
+        t.cancel()
+        self.assertRaises(asyncio.CancelledError, loop.run_until_complete, t)
 
     def test_wait_for(self):