CODEWITHSUNDEEP
flaskceleryflask-sqlalchemy
Rohit Kurdukar
Rohit Kurdukar

Reputation: 41

how to store arguments in SQL alchemy backed which are passed to celery task in flask app

i am working on flask app which initiate large no of tasks in background using celery , and i am using Redis as message broker queue and SQL alchemy as celery back-end.

By default, i can see "Results" are stored in back-end in "results" column for celery_taskmeta table , but i would like to store args as well which was passed to task .

And i would like to retrieve them as well in future . Is there any way i can store them in my current back-end.

Thanks

Upvotes: 4

Views: 1258

Answers (2)

Junchao
Junchao

Reputation: 1

result_backend=True does not work when loading config using app.config_from_object().

You have to manually update config using app.conf.update(result_backend=True).

Upvotes: 0

Sowjanya R Bhat
Sowjanya R Bhat

Reputation: 1168

You can use this parameter in your settings =>

result_extended = True

Enables extended task result attributes (name, args, kwargs, worker, retries, queue, delivery_info) to be written to backend.

Check out the link for explanation : https://docs.celeryproject.org/en/stable/userguide/configuration.html#result-extended

Upvotes: 3

Related Questions