avoid the whole process taken down by a single _process_result

This commit is contained in:
lilydjwg 2022-06-12 12:22:07 +08:00
parent 88cbdd925c
commit e683476fb2
1 changed files with 5 additions and 1 deletions

View File

@ -366,7 +366,11 @@ async def process_result(
try: try:
while True: while True:
r = await result_q.get() r = await result_q.get()
try:
r1 = _process_result(r) r1 = _process_result(r)
except Exception as e:
logger.exception('error processing result', result=r)
r1 = e
if isinstance(r1, Exception): if isinstance(r1, Exception):
entry_waiter.set_exception(r.name, r1) entry_waiter.set_exception(r.name, r1)
has_failures = True has_failures = True