|
@@ -576,7 +576,7 @@ class AsynPool(_pool.Pool):
|
|
|
|
|
|
def on_process_down(proc):
|
|
def on_process_down(proc):
|
|
"""Called when a worker process exits."""
|
|
"""Called when a worker process exits."""
|
|
- if proc.dead:
|
|
|
|
|
|
+ if getattr(proc, 'dead', None):
|
|
return
|
|
return
|
|
process_flush_queues(proc)
|
|
process_flush_queues(proc)
|
|
_remove_from_index(
|
|
_remove_from_index(
|