2022-12-22T11:39:50.270152+0000 | fastapi_websocket_pubsub.event_notifier | INFO  | calling subscription callbacks: topic=policy_data, subscription_id=bdc5ac2f2d584b16a1ffe24b995bc124, subscriber_id=32a8cd1620684f599661349a7fcac518
2022-12-22T11:39:50.270573+0000 | fastapi_websocket_pubsub.rpc_event_me...| INFO  | Notifying other side: subscription={'id': 'bdc5ac2f2d584b16a1ffe24b995bc124', 'subscriber_id': '32a8cd1620684f599661349a7fcac518', 'topic': 'policy_data', 'notifier_id': None}, data={'id': '0813e67c-b321-4f6f-b3ff-36bbbf360d12', 'entries': [{'url': '', 'data': {'event_user_id': 283790, 'blocked': False}, 'config': None, 'topics': ['policy_data'], 'dst_path': 'events/da18d2cc-a6ee-4f22-923d-fcb36ea0b71e/members/eb74a77e-4e01-4fad-a617-3b910160717a/', 'save_method': 'PATCH'}], 'reason': None, 'callback': {'callbacks': []}}, channel_id=32a8cd1620684f599661349a7fcac518
2022-12-22T11:39:50.271282+0000 | fastapi_websocket_pubsub.event_notifier |ERROR  | Failed to notify subscriber sub_id=32a8cd1620684f599661349a7fcac518 with topic=policy_data
Traceback (most recent call last):

  File "/usr/local/bin/gunicorn", line 33, in <module>
    sys.exit(load_entry_point('gunicorn==20.1.0', 'console_scripts', 'gunicorn')())
    │   │    └ <function importlib_load_entry_point at 0x7f72786cae60>
    │   └ <built-in function exit>
    └ <module 'sys' (built-in)>
  File "/usr/local/lib/python3.10/site-packages/gunicorn/app/wsgiapp.py", line 67, in run
    WSGIApplication("%(prog)s [OPTIONS] [APP_MODULE]").run()
    └ <class 'gunicorn.app.wsgiapp.WSGIApplication'>
  File "/usr/local/lib/python3.10/site-packages/gunicorn/app/base.py", line 231, in run
    super().run()
  File "/usr/local/lib/python3.10/site-packages/gunicorn/app/base.py", line 72, in run
    Arbiter(self).run()
    │       └ <gunicorn.app.wsgiapp.WSGIApplication object at 0x7f72786abee0>
    └ <class 'gunicorn.arbiter.Arbiter'>
  File "/usr/local/lib/python3.10/site-packages/gunicorn/arbiter.py", line 202, in run
    self.manage_workers()
    │    └ <function Arbiter.manage_workers at 0x7f7277b8b010>
    └ <gunicorn.arbiter.Arbiter object at 0x7f72776abd60>
  File "/usr/local/lib/python3.10/site-packages/gunicorn/arbiter.py", line 551, in manage_workers
    self.spawn_workers()
    │    └ <function Arbiter.spawn_workers at 0x7f7277b8b130>
    └ <gunicorn.arbiter.Arbiter object at 0x7f72776abd60>
  File "/usr/local/lib/python3.10/site-packages/gunicorn/arbiter.py", line 622, in spawn_workers
    self.spawn_worker()
    │    └ <function Arbiter.spawn_worker at 0x7f7277b8b0a0>
    └ <gunicorn.arbiter.Arbiter object at 0x7f72776abd60>
  File "/usr/local/lib/python3.10/site-packages/gunicorn/arbiter.py", line 589, in spawn_worker
    worker.init_process()
    │      └ <function UvicornWorker.init_process at 0x7f7276374160>
    └ <uvicorn.workers.UvicornWorker object at 0x7f72766e0940>
  File "/usr/local/lib/python3.10/site-packages/uvicorn/workers.py", line 66, in init_process
    super(UvicornWorker, self).init_process()
          │              └ <uvicorn.workers.UvicornWorker object at 0x7f72766e0940>
          └ <class 'uvicorn.workers.UvicornWorker'>
  File "/usr/local/lib/python3.10/site-packages/gunicorn/workers/base.py", line 142, in init_process
    self.run()
    │    └ <function UvicornWorker.run at 0x7f72763743a0>
    └ <uvicorn.workers.UvicornWorker object at 0x7f72766e0940>
  File "/usr/local/lib/python3.10/site-packages/uvicorn/workers.py", line 98, in run
    return asyncio.run(self._serve())
           │       │   │    └ <function UvicornWorker._serve at 0x7f7276374310>
           │       │   └ <uvicorn.workers.UvicornWorker object at 0x7f72766e0940>
           │       └ <function run at 0x7f727771dab0>
           └ <module 'asyncio' from '/usr/local/lib/python3.10/asyncio/__init__.py'>
  File "/usr/local/lib/python3.10/asyncio/runners.py", line 44, in run
    return loop.run_until_complete(main)
           │    │                  └ <coroutine object UvicornWorker._serve at 0x7f7273741230>
           │    └ <method 'run_until_complete' of 'uvloop.loop.Loop' objects>
           └ <uvloop.Loop running=True closed=False debug=False>
> File "/usr/local/lib/python3.10/site-packages/fastapi_websocket_pubsub/event_notifier.py", line 220, in callback_subscribers
    await self.trigger_callback(data, topic, subscriber_id, event)
          │    │                │     │      │              └ Subscription(id='bdc5ac2f2d584b16a1ffe24b995bc124', subscriber_id='32a8cd1620684f599661349a7fcac518', topic='policy_data', ca...
          │    │                │     │      └ '32a8cd1620684f599661349a7fcac518'
          │    │                │     └ 'policy_data'
          │    │                └ {'id': '0813e67c-b321-4f6f-b3ff-36bbbf360d12', 'entries': [{'url': '', 'data': {'event_user_id': 283790, 'blocked': False}, '...
          │    └ <function EventNotifier.trigger_callback at 0x7f7275da64d0>
          └ <fastapi_websocket_pubsub.websocket_rpc_event_notifier.WebSocketRpcEventNotifier object at 0x7f72737542e0>
  File "/usr/local/lib/python3.10/site-packages/fastapi_websocket_pubsub/event_notifier.py", line 178, in trigger_callback
    await subscription.callback(subscription, data)
          │            │        │             └ {'id': '0813e67c-b321-4f6f-b3ff-36bbbf360d12', 'entries': [{'url': '', 'data': {'event_user_id': 283790, 'blocked': False}, '...
          │            │        └ Subscription(id='bdc5ac2f2d584b16a1ffe24b995bc124', subscriber_id='32a8cd1620684f599661349a7fcac518', topic='policy_data', ca...
          │            └ <function RpcEventServerMethods.subscribe.<locals>.callback at 0x7f7270192d40>
          └ Subscription(id='bdc5ac2f2d584b16a1ffe24b995bc124', subscriber_id='32a8cd1620684f599661349a7fcac518', topic='policy_data', ca...
  File "/usr/local/lib/python3.10/site-packages/fastapi_websocket_pubsub/rpc_event_methods.py", line 26, in callback
    await self.channel.other.notify(subscription=sub, data=data)
          │    │                                 │         └ {'id': '0813e67c-b321-4f6f-b3ff-36bbbf360d12', 'entries': [{'url': '', 'data': {'event_user_id': 283790, 'blocked': False}, '...
          │    │                                 └ Subscription(id='bdc5ac2f2d584b16a1ffe24b995bc124', subscriber_id='32a8cd1620684f599661349a7fcac518', topic='policy_data', no...
          │    └ <property object at 0x7f7275d0b010>
          └ <fastapi_websocket_pubsub.rpc_event_methods.RpcEventServerMethods object at 0x7f72594cfbe0>
  File "/usr/local/lib/python3.10/site-packages/fastapi_websocket_rpc/rpc_channel.py", line 397, in call
    promise = await self.async_call(name, args)
                    │    │          │     └ {'subscription': Subscription(id='bdc5ac2f2d584b16a1ffe24b995bc124', subscriber_id='32a8cd1620684f599661349a7fcac518', topic=...
                    │    │          └ 'notify'
                    │    └ <function RpcChannel.async_call at 0x7f7275da4280>
                    └ <fastapi_websocket_rpc.rpc_channel.RpcChannel object at 0x7f72594cf3a0>
  File "/usr/local/lib/python3.10/site-packages/fastapi_websocket_rpc/rpc_channel.py", line 389, in async_call
    await self.send(msg)
          │    │    └ RpcMessage(request=RpcRequest(method='notify', arguments={'subscription': Subscription(id='bdc5ac2f2d584b16a1ffe24b995bc124',...
          │    └ <function RpcChannel.send at 0x7f7275d836d0>
          └ <fastapi_websocket_rpc.rpc_channel.RpcChannel object at 0x7f72594cf3a0>
  File "/usr/local/lib/python3.10/site-packages/fastapi_websocket_rpc/rpc_channel.py", line 192, in send
    await self.socket.send(data)
          │    │      │    └ RpcMessage(request=RpcRequest(method='notify', arguments={'subscription': Subscription(id='bdc5ac2f2d584b16a1ffe24b995bc124',...
          │    │      └ <function JsonSerializingWebSocket.send at 0x7f7275da4820>
          │    └ <fastapi_websocket_rpc.simplewebsocket.JsonSerializingWebSocket object at 0x7f72594cf010>
          └ <fastapi_websocket_rpc.rpc_channel.RpcChannel object at 0x7f72594cf3a0>
  File "/usr/local/lib/python3.10/site-packages/fastapi_websocket_rpc/simplewebsocket.py", line 33, in send
    await self._websocket.send(self._serialize(msg))
          │    │          │    │    │          └ RpcMessage(request=RpcRequest(method='notify', arguments={'subscription': Subscription(id='bdc5ac2f2d584b16a1ffe24b995bc124',...
          │    │          │    │    └ <function JsonSerializingWebSocket._serialize at 0x7f7275da4700>
          │    │          │    └ <fastapi_websocket_rpc.simplewebsocket.JsonSerializingWebSocket object at 0x7f72594cf010>
          │    │          └ <property object at 0x7f7275d9d670>
          │    └ <fastapi_websocket_rpc.websocket_rpc_endpoint.WebSocketSimplifier object at 0x7f72594cdf90>
          └ <fastapi_websocket_rpc.simplewebsocket.JsonSerializingWebSocket object at 0x7f72594cf010>
  File "/usr/local/lib/python3.10/site-packages/starlette/websockets.py", line 163, in send_text
    await self.send({"type": "websocket.send", "text": data})
          │    │                                       └ '{"request": {"method": "notify", "arguments": {"subscription": {"id": "bdc5ac2f2d584b16a1ffe24b995bc124", "subscriber_id": "...
          │    └ <function WebSocket.send at 0x7f7275ea7880>
          └ <starlette.websockets.WebSocket object at 0x7f72594ceec0>
  File "/usr/local/lib/python3.10/site-packages/starlette/websockets.py", line 85, in send
    await self._send(message)
          │    │     └ {'type': 'websocket.send', 'text': '{"request": {"method": "notify", "arguments": {"subscription": {"id": "bdc5ac2f2d584b16a1...
          │    └ <function ExceptionMiddleware.__call__.<locals>.sender at 0x7f727025fbe0>
          └ <starlette.websockets.WebSocket object at 0x7f72594ceec0>
  File "/usr/local/lib/python3.10/site-packages/starlette/middleware/exceptions.py", line 65, in sender
    await send(message)
          │    └ {'type': 'websocket.send', 'text': '{"request": {"method": "notify", "arguments": {"subscription": {"id": "bdc5ac2f2d584b16a1...
          └ <bound method WebSocketProtocol.asgi_send of <uvicorn.protocols.websockets.websockets_impl.WebSocketProtocol object at 0x7f72...
  File "/usr/local/lib/python3.10/site-packages/uvicorn/protocols/websockets/websockets_impl.py", line 329, in asgi_send
    raise RuntimeError(msg % message_type)
                       │     └ 'websocket.send'
                       └ "Unexpected ASGI message '%s', after sending 'websocket.close'."

RuntimeError: Unexpected ASGI message 'websocket.send', after sending 'websocket.close'.