if self._must_cancel:

# Task is cancelled right before coro stops.

self._must_cancel = False

super().set_exception(exceptions.CancelledError())

super().cancel()

else:

super().set_result(exc.value)

except exceptions.CancelledError:

return 12

t = self.new_task(loop, task())

self.assertFalse(t.cancelled())

self.assertRaises(

asyncio.CancelledError, loop.run_until_complete, t)

self.assertTrue(t.done())

self.assertTrue(t.cancelled())

self.assertFalse(t._must_cancel) # White-box test.

self.assertFalse(t.cancel())

return 12

t = self.new_task(loop, task())

self.assertFalse(t.cancelled())

self.assertRaises(

asyncio.CancelledError, loop.run_until_complete, t)

self.assertTrue(t.done())

self.assertTrue(t.cancelled())

self.assertFalse(t._must_cancel) # White-box test.

self.assertFalse(t.cancel())

asyncio: Fix inconsistent immediate Task cancellation

if (_PyGen_FetchStopIterationValue(&o) == 0) {

/* The error is StopIteration and that means that

the underlying coroutine has resolved */

PyObject *res;

if (task->task_must_cancel) {

// Task is cancelled right before coro stops.

Py_DECREF(o);

task->task_must_cancel = 0;

et = asyncio_CancelledError;

Py_INCREF(et);

ev = NULL;

tb = NULL;

goto set_exception;

res = future_cancel((FutureObj*)task);

}

else {

res = future_set_result((FutureObj*)task, o);

}

PyObject *res = future_set_result((FutureObj*)task, o);

Py_DECREF(o);

if (res == NULL) {

return NULL;

}