Application instance took too long to shut down and was killed

[Elabbasy00]

• Your OS and runtime environment, and browser if applicable
  ubuntu 20.04 digital ocean droplet

• How you're running Channels (runserver? daphne/runworker? Nginx/Apache in front?)
  daphne / Nginx

• Console logs and full tracebacks of any errors

2022-03-03 21:04:54,257 ERROR    Exception inside application: Attempt to send on a closed protocol
Traceback (most recent call last):
  File "/usr/local/lib/python3.8/site-packages/channels/routing.py", line 71, in __call__
    return await application(scope, receive, send)
  File "/usr/local/lib/python3.8/site-packages/channels/sessions.py", line 47, in __call__
    return await self.inner(dict(scope, cookies=cookies), receive, send)
  File "/usr/local/lib/python3.8/site-packages/channels/sessions.py", line 263, in __call__
    return await self.inner(wrapper.scope, receive, wrapper.send)
  File "/usr/local/lib/python3.8/site-packages/channels/auth.py", line 185, in __call__
    return await super().__call__(scope, receive, send)
  File "/usr/local/lib/python3.8/site-packages/channels/middleware.py", line 26, in __call__
    return await self.inner(scope, receive, send)
  File "/usr/local/lib/python3.8/site-packages/channels/routing.py", line 150, in __call__
    return await application(
  File "/usr/local/lib/python3.8/site-packages/channels/consumer.py", line 94, in app
    return await consumer(scope, receive, send)
  File "/usr/local/lib/python3.8/site-packages/channels/consumer.py", line 58, in __call__
    await await_many_dispatch(
  File "/usr/local/lib/python3.8/site-packages/channels/utils.py", line 51, in await_many_dispatch
    await dispatch(result)
  File "/usr/local/lib/python3.8/site-packages/channels/consumer.py", line 73, in dispatch
    await handler(message)
  File "/app/backend/server/./script/consumers.py", line 242, in chat_message
    await self.send(text_data=json.dumps({
  File "/usr/local/lib/python3.8/site-packages/channels/generic/websocket.py", line 209, in send
    await super().send({"type": "websocket.send", "text": text_data})
  File "/usr/local/lib/python3.8/site-packages/channels/consumer.py", line 81, in send
    await self.base_send(message)
  File "/usr/local/lib/python3.8/site-packages/channels/sessions.py", line 226, in send
    return await self.real_send(message)
  File "/usr/local/lib/python3.8/site-packages/daphne/server.py", line 234, in handle_reply
    protocol.handle_reply(message)
  File "/usr/local/lib/python3.8/site-packages/daphne/ws_protocol.py", line 202, in handle_reply
    self.serverSend(message["text"], False)
  File "/usr/local/lib/python3.8/site-packages/daphne/ws_protocol.py", line 256, in serverSend
    self.sendMessage(content.encode("utf8"), binary)
  File "/usr/local/lib/python3.8/site-packages/autobahn/websocket/protocol.py", line 2217, in sendMessage
    raise Disconnected("Attempt to send on a closed protocol")
autobahn.exception.Disconnected: Attempt to send on a closed protocol

2022-03-04 00:02:50,902 WARNING  Application instance <Task pending name='Task-672440' coro=<ProtocolTypeRouter.__call__() running at /usr/local/lib/python3.8/site-packages/channels/routing.py:71> wait_for=<Future pending cb=[_chain_future.<locals>._call_check_cancel() at /usr/local/lib/python3.8/asyncio/futures.py:360, <TaskWakeupMethWrapper object at 0x7efebc91aa30>()]>> for connection <WebSocketProtocol client=['172.19.0.6', 43914] path=b'/ws/script/Md_Aman/'> took too long to shut down and was killed.

consumers.py

class ScriptConsumers(AsyncWebsocketConsumer):
   
    def update_user_incr(self, user):
        '''
        update online status
        '''
        try:
            user = LogFor.objects.get(username=user.replace("_", " "))
            user.online = 1
            user.save()
        except:
            return

    def update_user_decr(self, user):
        '''
        update online status
        '''
        try:
            user = LogFor.objects.get(username=user.replace("_", " "))
            user.online = 0
            user.save()
        except:
            return

    async def connect(self):
        try:
            self.username = self.scope['url_route']['kwargs']['username']
            await database_sync_to_async(self.update_user_incr)(self.username)
        except Exception as e:
            print("Connect() : ", e)

        self.room_group_name = 'logs'  
        # Join room group
        await self.channel_layer.group_add(
            self.room_group_name,
            self.channel_name
        )

        await self.accept()

    async def disconnect(self, close_code):
        # Leave room group
        try:
            if(self.username):
                await database_sync_to_async(self.update_user_decr)(self.username)

            await self.channel_layer.group_discard(
                self.room_group_name,
                self.channel_name
            )
        except Exception as e:
            print("Disconnect() : ", e)
            print("Disconnect() close_Code : ", close_code)
            await self.channel_layer.group_discard(
                self.room_group_name,
                self.channel_name
            )


    commands = {
        "fetch_logs": fetch_logs,
        "new_log": new_log   # mabye long proccess
    }


    async def receive(self, text_data):
        data = json.loads(text_data)
        await self.commands[data['command']](self, data)



    async def send_logs_data(self, data):
        try:
            await self.channel_layer.group_send(
                self.room_group_name,
                {
                    'type': 'chat_message',
                    'message': data
                }
            )
        except Exception as e:
            print("send_logs_data() : ", e)


    async def send_logs(self, message):
        try:
            await self.send(text_data=json.dumps(message))
        except Exception as e:
            print("send_logs() : ", e)

[carltongibson]

There's too much going on here to realistically see what the issue is. If you can reduce it to a minimal example just using Channels we might be able to see something. Otherwise it could well be an Nginx config issue, that we can't really help with.

[Elabbasy00]

I don't know what limit I can reduce the code to because I don't know what exactly caused the problem

I only provided the code for Django and Channels
And the error message