How would one use this progress bar when a task is wrapped in a Django transaction.on_commit? about celery-progress HOT 4 OPEN

To overcome this, I gave the task a custom id.

from celery-progress.

Could you elaborate a little more on how you got it to work?

Thanks!

Mark

from celery-progress.

I didn't run this code. But it gives you the general idea.

# pre-generate a random id
custom_id = celery.utils.gen_unique_id()

# set task id to custom id
task_function = lambda: my_task.apply_async(args, task_id=custom_id)

# instead of passing my_task.apply_async directly, it's wrapped in a lambda function so we can give it arguments
transaction.on_commit(task_function)

from celery-progress.

Thanks!

Giving a task a custom task_id is a new concept for me. While we were talking, I implemented my progress bar using my Django site's MySQL db and uuid.uuid4().hex to generate a unique ID outside of the celery task, but I will take a look at using this approach when I have some free time. Yours will certainly be more efficient than periodically hitting the db to get the progress amount in my view. But, it does work!

Mark

from celery-progress.