fixes

Author: kumaraditya303

Lib/asyncio/base_events.py

@@ -1940,7 +1940,7 @@ def call_exception_handler(self, context):
 
     def _add_callback(self, handle):
         """Add a Handle to _ready."""
-        if not handle.cancelled():
+        if not handle._cancelled:
             self._ready.append(handle)
 
     def _add_callback_signalsafe(self, handle):
@@ -1969,7 +1969,7 @@ def _run_once(self):
             # is too high
             new_scheduled = []
             for handle in self._scheduled:
-                if handle.cancelled():
+                if handle._cancelled:
                     handle._scheduled = False
                 else:
                     new_scheduled.append(handle)
@@ -2019,7 +2019,7 @@ def _run_once(self):
         ntodo = len(self._ready)
         for i in range(ntodo):
             handle = self._ready.popleft()
-            if handle.cancelled():
+            if handle._cancelled:
                 continue
             if self._debug:
                 try:

Lib/asyncio/events.py

@@ -129,6 +129,8 @@ def cancelled(self):
 
     def _run(self):
         with self._lock:
+            if self._cancelled:
+                return
             return super()._run()
 
 

Lib/asyncio/unix_events.py

@@ -138,7 +138,7 @@ def _handle_signal(self, sig):
         handle = self._signal_handlers.get(sig)
         if handle is None:
             return  # Assume it's some race condition.
-        if handle.cancelled():
+        if handle._cancelled:
             self.remove_signal_handler(sig)  # Remove it properly.
         else:
             self._add_callback_signalsafe(handle)

Lib/test/test_asyncio/test_tasks.py

@@ -1810,11 +1810,11 @@ def call_later(delay, callback, *args):
         loop.call_later = call_later
         test_utils.run_briefly(loop)
 
-        self.assertFalse(handle.cancelled())
+        self.assertFalse(handle._cancelled)
 
         t.cancel()
         test_utils.run_briefly(loop)
-        self.assertTrue(handle.cancelled())
+        self.assertTrue(handle._cancelled)
 
     def test_task_cancel_sleeping_task(self):