django-nose单元测试芹菜任务...缺少数据库数据

Question

我正在使用django-nose为芹菜任务编写单元测试。这是相当典型的；一个空白的测试数据库(REUSE_DB=0)，它在测试时通过一个fixture预先填充。

我遇到的问题是，即使TestCase正在加载fixture，并且我可以从测试方法访问对象，在异步芹菜任务中执行时，同样的查询也会失败。

我已经检查了测试方法和测试任务中的默认“settings.DATABASES”是否相同。我还验证了正在测试的任务在作为常规方法调用调用时行为是否正确。

这就是我没有想法的地方。

下面是一个示例：

class MyTest(TestCase):
    fixtures = ['test_data.json']

    def setUp(self):
        settings.CELERY_ALWAYS_EAGER = True # seems to be required; if not I get socket errors for Rabbit
        settings.CELERY_EAGER_PROPAGATES_EXCEPTIONS = True # exposes errors in the code under test.

    def test_city(self):
        self.assertIsNotNone(City.objects.get(name='brisbane'))
        myTask.delay(city_name='brisbane').get()
        # The following works fine: myTask('brisbane')

from celery.task import task

@task()
def myTask(city_name):
    c = City.objects.count() # gives 0
    my_city = City.objects.get(name=city_name) # raises DoesNotExist exception
    return

Answer 1

这听起来很像django-celery2.5中的一个bug，它在2.5.2：https://github.com/celery/django-celery/pull/116中得到了修复

对该bug的简要描述是，django-celery加载程序在执行任务之前关闭了DB连接，甚至是急切的任务。因为测试在事务中运行，所以用于任务执行的新连接看不到在setUp中创建的数据。