|
@@ -796,7 +796,7 @@ class AsynPool(_pool.Pool):
|
|
|
|
|
|
def on_not_recovering(proc, fd, job, exc):
|
|
|
error('Process inqueue damaged: %r %r: %r',
|
|
|
- proc, proc.exitcode, exc, exc_info=1))
|
|
|
+ proc, proc.exitcode, exc, exc_info=1)
|
|
|
if proc._is_alive():
|
|
|
proc.terminate()
|
|
|
hub.remove(fd)
|