Open Alain1405 opened 1 year ago
Additional info:
add_answer_to_vectorstore
is executedsync_to_async(async_task)(add_answer_to_vectorstore, new_answer)
works but I don't see any logs in cluster, so I suppose the task is executed synchronouslyHi @Alain1405 - you might be more likely to get a response from https://github.com/django-q2/django-q2 which is an active fork of this project
I use Django Channels to manage websockets. I have configured Django-Q to use Django ORM as a broker.
In the WS message handler I store some data in DB, then I want to perform some async tasks, here is some sample code
On the
async_task
call I getYou cannot call this from an async context - use a thread or sync_to_async.
. I could not find any instance of such error for Django-Q but I suspect it's because of using Django ORM as a broker (model.save() cannot be call within an async context, we should use .asave as in my code). Has anyone else stumbled upon this? Any solution?