@@ -245,23 +245,23 @@ def uncancel(self):
245
245
return self ._num_cancels_requested
246
246
247
247
def __eager_start (self ):
248
- prev_task = _swap_current_task (self ._loop , self )
248
+ prev_task = _py_swap_current_task (self ._loop , self )
249
249
try :
250
- _register_eager_task (self )
250
+ _py_register_eager_task (self )
251
251
try :
252
252
self ._context .run (self .__step_run_and_handle_result , None )
253
253
finally :
254
- _unregister_eager_task (self )
254
+ _py_unregister_eager_task (self )
255
255
finally :
256
256
try :
257
- curtask = _swap_current_task (self ._loop , prev_task )
257
+ curtask = _py_swap_current_task (self ._loop , prev_task )
258
258
assert curtask is self
259
259
finally :
260
260
if self .done ():
261
261
self ._coro = None
262
262
self = None # Needed to break cycles when an exception occurs.
263
263
else :
264
- _register_task (self )
264
+ _py_register_task (self )
265
265
266
266
def __step (self , exc = None ):
267
267
if self .done ():
@@ -273,11 +273,11 @@ def __step(self, exc=None):
273
273
self ._must_cancel = False
274
274
self ._fut_waiter = None
275
275
276
- _enter_task (self ._loop , self )
276
+ _py_enter_task (self ._loop , self )
277
277
try :
278
278
self .__step_run_and_handle_result (exc )
279
279
finally :
280
- _leave_task (self ._loop , self )
280
+ _py_leave_task (self ._loop , self )
281
281
self = None # Needed to break cycles when an exception occurs.
282
282
283
283
def __step_run_and_handle_result (self , exc ):
0 commit comments