引发异常时芹菜工人挂起

问题描述

我有一个 django 应用程序，其中包含一堆 celery 任务，这些任务会为一系列参数重复。这些任务是使用 shared_task 装饰器定义的，我使用 rabbitmq 作为后端。如果任何任务引发异常，则工作人员会冻结，并且不会执行任何剩余任务。这是一个示例任务：

@shared_task
def my_task(table_name:str):
  conn = get_sqlalchemy_engine()
  try:
     conn.execute("SELECT * from " + table_name +;")
  except e:
     raise e

我看到了 this question 但这似乎不是我的情况。我不希望重新尝试失败的任务，或发送电子邮件或任何其他内容。我只是想让工作人员继续执行队列中的下一个任务。是否有任务级别或工作人员级别的配置可以设置为达到此效果？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）