Django celery транзакция базы данных автофиксация

Я использую функцию celery group для группировки моих async-задач, например

job_flow = group(
            tasks.init_a.si(id, data),
            tasks.init_b.si(id, data)
            )
res = job_flow()

В функции init_a у меня есть некоторый код

ta = tablea.objects.get(id=id)
ta.desc = 'done'
ta.save()

Затем в init_b(), я должен проверить ta.desc выполнен или нет, но я не могу заставить ta.desc быть выполненным.

Но я использую ./manage shell для проверки того, что значение ta.desc изменено на done.

Почему я не могу в init_b() получить реальное значение ta.desc?

Django (1.5.6) сельдерей (3.1.23)

Вернуться на верх