芹菜任务中出现异常

Question

任务.py

@shared_task(bind=True, default_retry_delay=60, max_retries=3)
def index_city(self, pk):
    from .models import City
    try:
        city = City.objects.get(pk=pk)
    except City.ObjectDoesNotExist:
        self.retry()
    #Do stuff here with City

当我毫不拖延地调用上述任务时，它可以毫无问题地工作。当我在运行芹菜的开发环境中使用.delay调用任务时，它也可以正常工作。但是，在生产中，会抛出以下异常：

type object 'City' has no attribute 'ObjectDoesNotExist'

我添加了time.sleep(10)以排除任何竞争条件，但这没有任何效果，并且仍然抛出了异常。事实上，该对象确实存在，因此似乎没有发生City的内联导入（内联导入是为了防止循环导入问题）。如果有任何解决此问题的想法，我们将不胜感激。

堆栈

• Django 1.8.5
• Python 2.7.10
• sqlite在dev上，postgresql在production上

Answer 1

您应该使用City.DoesNotExist或django.core.exceptions.ObjectDoesNotExist而不是City.ObjectDoesNotExist看见https://docs.djangoproject.com/en/1.9/ref/exceptions/#objectdoesnotexist