2
0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-22 09:32:21 +00:00

Keep reap loop going on error

This commit is contained in:
Jarrod Johnson 2024-04-09 16:18:24 -04:00
parent 01722c18c4
commit ceaf641c1a

View File

@ -331,7 +331,11 @@ def cleanit():
for nn in list(syncrunners):
if syncrunners[nn].dead:
if nn in toreap:
syncrunners[nn].wait()
try:
syncrunners[nn].wait()
except Exception as e:
print(repr(e))
pass
del syncrunners[nn]
del toreap[nn]
else: