@@ -309,7 +309,7 @@ async def request_task():
309309 except Exception :
310310 logging .exception ("error in client message handler" )
311311
312- runnning_request_task = self .loop .create_task (request_task ())
312+ running_request_task = self .loop .create_task (request_task ())
313313
314314 try :
315315 async for out_msg in queue_as_aiter (out_msg_queue ):
@@ -323,8 +323,8 @@ async def request_task():
323323 logging .info ("Never received startup from peer %s that disconnected" , peer )
324324 return
325325
326- runnning_request_task .cancel ()
327- await runnning_request_task
326+ running_request_task .cancel ()
327+ await running_request_task
328328 logging .debug ("client aborted %s, cancelled: %s" , session , context .cancelled ())
329329
330330 def _add_default_place (self , name ):
@@ -405,7 +405,7 @@ async def request_task():
405405 except Exception :
406406 logging .exception ("error in exporter message handler" )
407407
408- runnning_request_task = self .loop .create_task (request_task ())
408+ running_request_task = self .loop .create_task (request_task ())
409409
410410 try :
411411 async for cmd in queue_as_aiter (command_queue ):
@@ -419,8 +419,8 @@ async def request_task():
419419 except Exception :
420420 logging .exception ("error in exporter command handler" )
421421 finally :
422- runnning_request_task .cancel ()
423- await runnning_request_task
422+ running_request_task .cancel ()
423+ await running_request_task
424424
425425 try :
426426 session = self .exporters .pop (peer )
0 commit comments