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)