@@ -309,7 +309,7 @@ async def request_task():
309
309
except Exception :
310
310
logging .exception ("error in client message handler" )
311
311
312
- runnning_request_task = self .loop .create_task (request_task ())
312
+ running_request_task = self .loop .create_task (request_task ())
313
313
314
314
try :
315
315
async for out_msg in queue_as_aiter (out_msg_queue ):
@@ -323,8 +323,8 @@ async def request_task():
323
323
logging .info ("Never received startup from peer %s that disconnected" , peer )
324
324
return
325
325
326
- runnning_request_task .cancel ()
327
- await runnning_request_task
326
+ running_request_task .cancel ()
327
+ await running_request_task
328
328
logging .debug ("client aborted %s, cancelled: %s" , session , context .cancelled ())
329
329
330
330
def _add_default_place (self , name ):
@@ -405,7 +405,7 @@ async def request_task():
405
405
except Exception :
406
406
logging .exception ("error in exporter message handler" )
407
407
408
- runnning_request_task = self .loop .create_task (request_task ())
408
+ running_request_task = self .loop .create_task (request_task ())
409
409
410
410
try :
411
411
async for cmd in queue_as_aiter (command_queue ):
@@ -419,8 +419,8 @@ async def request_task():
419
419
except Exception :
420
420
logging .exception ("error in exporter command handler" )
421
421
finally :
422
- runnning_request_task .cancel ()
423
- await runnning_request_task
422
+ running_request_task .cancel ()
423
+ await running_request_task
424
424
425
425
try :
426
426
session = self .exporters .pop (peer )
0 commit comments