Django 5.0 introduced the cancellation of Async views. But when usin

allauth currently does not support async, see <a class="issue-link js-issue-link" data

This could work I think: <div class="highlight highlight-source-python notranslate

Updated: <div class="highlight highlight-source-python notranslate position-relati

Async view cancellation freeze asgi worker when using django-allauth about django-allauth HOT 6 CLOSED

jrobichaud commented on June 5, 2024

Async view cancellation freeze asgi worker when using django-allauth

from django-allauth.

Comments (6)

pennersr commented on June 5, 2024

allauth currently does not support async, see #3546. Likely, this needs to be applied to the middleware:

https://docs.djangoproject.com/en/4.2/topics/http/middleware/#asynchronous-support

Can you check if that fixes the issue? A PR is welcome.

from django-allauth.

pennersr commented on June 5, 2024

I have a fix for this in the pipeline...

from django-allauth.

jrobichaud commented on June 5, 2024

This could work I think:

from asgiref.sync import iscoroutinefunction, markcoroutinefunction
from asgiref import sync
from allauth.core import context
from allauth.account import middleware


class AccountMiddleware(middleware.AccountMiddleware):
    async_capable = True
    sync_capable = True

    def __init__(self, get_response):
        self.get_response = get_response
        if iscoroutinefunction(self.get_response):
            markcoroutinefunction(self)

    def __call__(self, request):
        if iscoroutinefunction(self):
            return self.__acall__(request)
        return super().__call__(request)

    async def __acall__(self, request):
        with context.request_context(request):
            response = await self.get_response(request)
            await sync.sync_to_async(self._remove_dangling_login)(request, response)
            return response

I did it using inheritance but the classes would have to be merged.

from django-allauth.

pennersr commented on June 5, 2024

Doesn't sync_to_async spawn a thread to run the sync code? In any case, I have avoided that here #3568 -- also not very pretty, doubling code, but it's what Django recommends.

from django-allauth.

jrobichaud commented on June 5, 2024

You are right, it is not required.

from django-allauth.

jrobichaud commented on June 5, 2024

Updated:

from asgiref.sync import iscoroutinefunction, markcoroutinefunction
from allauth.core import context
from allauth.account import middleware


class AccountMiddleware(middleware.AccountMiddleware):
    async_capable = True
    sync_capable = True

    def __init__(self, get_response):
        self.get_response = get_response
        if iscoroutinefunction(self.get_response):
            markcoroutinefunction(self)

    def __call__(self, request):
        if iscoroutinefunction(self):
            return self.__acall__(request)
        return super().__call__(request)

    async def __acall__(self, request):
        with context.request_context(request):
            response = await self.get_response(request)
            self._remove_dangling_login(request, response)
            return response