@@ -492,7 +492,9 @@ def _worker_process_sync(
492492 async def _process_runner ():
493493 while True :
494494 try :
495- process_request : Optional [_WorkerProcessRequest ] = requests_queue .get_nowait ()
495+ process_request : Optional [_WorkerProcessRequest ] = (
496+ requests_queue .get_nowait ()
497+ )
496498 except multiprocessing .queues .Empty :
497499 # yield control to the event loop
498500 await asyncio .sleep (settings .default_async_loop_sleep )
@@ -515,7 +517,7 @@ async def _process_runner():
515517
516518 try :
517519 asyncio .run (_process_runner ())
518- except Exception as exc :
520+ except Exception as exc : # noqa: BLE001
519521 logger .error (
520522 f"Error in worker process { process_id } : { exc } " ,
521523 exc_info = True ,
@@ -534,7 +536,9 @@ async def _process_runner():
534536
535537 while True :
536538 try :
537- process_request : Optional [_WorkerProcessRequest ] = requests_queue .get_nowait ()
539+ process_request : Optional [_WorkerProcessRequest ] = (
540+ requests_queue .get_nowait ()
541+ )
538542 except multiprocessing .queues .Empty :
539543 # yield control to event loop
540544 await asyncio .sleep (settings .default_async_loop_sleep )
@@ -568,7 +572,7 @@ def _task_done(_: asyncio.Task):
568572
569573 try :
570574 asyncio .run (_process_runner ())
571- except Exception as exc :
575+ except Exception as exc : # noqa: BLE001
572576 logger .error (
573577 f"Error in worker process { process_id } : { exc } " ,
574578 exc_info = True ,
0 commit comments