@@ -352,24 +352,23 @@ def __call__(self):
352352 asyncio .get_running_loop ()
353353 except RuntimeError :
354354 # There is no running loop
355-
355+
356356 # This can happen if the finalizer is called from a thread
357357 # without an event loop (e.g., the engine monitor).
358358 # In this case, we can't schedule async cleanup.
359359 # Do a best-effort synchronous cleanup of sockets.
360360 logger .warning (
361361 "Could not get event loop for async cleanup. "
362- "Tasks may not be cancelled, sockets will be closed."
363- )
362+ "Tasks may not be cancelled, sockets will be closed." )
364363 sockets = (self .output_socket , self .input_socket ,
365- self . first_req_send_socket , self .first_req_rcv_socket ,
366- self .stats_update_socket )
364+ self .first_req_send_socket ,
365+ self . first_req_rcv_socket , self .stats_update_socket )
367366 close_sockets (sockets )
368367 else :
369368 # There is a running loop.
370369 sockets = (self .output_socket , self .input_socket ,
371- self . first_req_send_socket , self .first_req_rcv_socket ,
372- self .stats_update_socket )
370+ self .first_req_send_socket ,
371+ self . first_req_rcv_socket , self .stats_update_socket )
373372
374373 tasks = (self .output_queue_task , self .stats_update_task )
375374
0 commit comments