@@ -492,7 +492,9 @@ def _worker_process_sync(
492
492
async def _process_runner ():
493
493
while True :
494
494
try :
495
- process_request : Optional [_WorkerProcessRequest ] = requests_queue .get_nowait ()
495
+ process_request : Optional [_WorkerProcessRequest ] = (
496
+ requests_queue .get_nowait ()
497
+ )
496
498
except multiprocessing .queues .Empty :
497
499
# yield control to the event loop
498
500
await asyncio .sleep (settings .default_async_loop_sleep )
@@ -515,7 +517,7 @@ async def _process_runner():
515
517
516
518
try :
517
519
asyncio .run (_process_runner ())
518
- except Exception as exc :
520
+ except Exception as exc : # noqa: BLE001
519
521
logger .error (
520
522
f"Error in worker process { process_id } : { exc } " ,
521
523
exc_info = True ,
@@ -534,7 +536,9 @@ async def _process_runner():
534
536
535
537
while True :
536
538
try :
537
- process_request : Optional [_WorkerProcessRequest ] = requests_queue .get_nowait ()
539
+ process_request : Optional [_WorkerProcessRequest ] = (
540
+ requests_queue .get_nowait ()
541
+ )
538
542
except multiprocessing .queues .Empty :
539
543
# yield control to event loop
540
544
await asyncio .sleep (settings .default_async_loop_sleep )
@@ -568,7 +572,7 @@ def _task_done(_: asyncio.Task):
568
572
569
573
try :
570
574
asyncio .run (_process_runner ())
571
- except Exception as exc :
575
+ except Exception as exc : # noqa: BLE001
572
576
logger .error (
573
577
f"Error in worker process { process_id } : { exc } " ,
574
578
exc_info = True ,
0 commit comments