所以我有一个芹菜设置,使用 RabbitMQ 作为代理,amqp 作为结果后端。
有时,我的任务会很长,因为我误解了所需的超时时间,而正如预期的那样,Celery 会杀死运行任务的工作人员。
问题是因为这是一个 celery 问题而不是任务问题,所以我应该从任务中向我发送电子邮件的错误处理将无法运行,并且我不会收到有关失败的消息。
当 Celery 因与 Celery 相关的错误而终止任务时,有没有办法让 Celery 自己做一些错误通知?就像on_timeout()
我可以在任务中创建的功能一样?我真的不想让调用进程进行错误处理,因为超时已经是几个小时了,进程运行了大约 30 秒。