Django celery database transaction auto commit

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

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

In init_a function, I have some code

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

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