我在调试这个时遇到了问题,没有太大的进展。我一直在运行异步celery 任务,有时会遇到信号11(这是一个递归/cpu绑定的函数,可能会遇到堆栈大小问题)。例如:
Process 'ForkPoolWorker-2' pid:5494 exited with 'signal 11 (SIGSEGV)'
我想修改我的celery 任务、任务类和请求来捕获这个并触发 on_failure
任务类的函数。但我一点运气都没有。我用redis后台运行这个。我发现的最相关的问题是如何处理sigsegv后celery 中的工人错误
我已经准备好了 acks_late=True
,但我不确定如何实现上述链接中描述的自定义请求/任务以获得所需的行为。同样,设置 acks_late=True, reject_on_worker_lost=True
将使任务重试,但我不知道如何在自定义请求中拦截它
暂无答案!
目前还没有任何答案,快来回答吧!