Django celery database transaction auto commit

I use celery group feature to group my async tasks, like

job_flow = group(
  , data),
  , data)
res = job_flow()

In init_a function, I have some code

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

Then in init_b(), I will to check the ta.desc is done or not, but I can not get the ta.desc to done.

But I use ./manage shell to check the ta.desc value is changed to done.

Why I can not in init_b() to get the real ta.desc value?

Django (1.5.6) celery (3.1.23)

Back to Top