celery / billiard

Multiprocessing Pool Extensions
Other
420 stars 251 forks source link

WorkerLostError Handling #408

Open Santifire92 opened 3 months ago

Santifire92 commented 3 months ago

Hi, @auvipy ! I have a question, how can we handle this scenario where a worker gets lost abruptly like with a sigkill? In the case of a timout i see you raise the exception so it gets propagated upwards but whit the worker lost it just gets catched and passes as nothing happened to the upper coordinator.

Can this be raised/what can i do? https://github.com/celery/billiard/blob/81cc94204ed70765a1f202b580e1063229af729c/billiard/pool.py#L1263-L1273