Skip to content

Commit d5796e6

Browse files
gh-129874: avoid mixing pure python and C implementation of asyncio (#129875)
1 parent 6fbf15f commit d5796e6

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

Lib/asyncio/tasks.py

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -245,23 +245,23 @@ def uncancel(self):
245245
return self._num_cancels_requested
246246

247247
def __eager_start(self):
248-
prev_task = _swap_current_task(self._loop, self)
248+
prev_task = _py_swap_current_task(self._loop, self)
249249
try:
250-
_register_eager_task(self)
250+
_py_register_eager_task(self)
251251
try:
252252
self._context.run(self.__step_run_and_handle_result, None)
253253
finally:
254-
_unregister_eager_task(self)
254+
_py_unregister_eager_task(self)
255255
finally:
256256
try:
257-
curtask = _swap_current_task(self._loop, prev_task)
257+
curtask = _py_swap_current_task(self._loop, prev_task)
258258
assert curtask is self
259259
finally:
260260
if self.done():
261261
self._coro = None
262262
self = None # Needed to break cycles when an exception occurs.
263263
else:
264-
_register_task(self)
264+
_py_register_task(self)
265265

266266
def __step(self, exc=None):
267267
if self.done():
@@ -273,11 +273,11 @@ def __step(self, exc=None):
273273
self._must_cancel = False
274274
self._fut_waiter = None
275275

276-
_enter_task(self._loop, self)
276+
_py_enter_task(self._loop, self)
277277
try:
278278
self.__step_run_and_handle_result(exc)
279279
finally:
280-
_leave_task(self._loop, self)
280+
_py_leave_task(self._loop, self)
281281
self = None # Needed to break cycles when an exception occurs.
282282

283283
def __step_run_and_handle_result(self, exc):

0 commit comments

Comments
 (0)