concurrent.futures.process.BrokenProcessPool: A process in the process pool was terminated abruptly while the future was running or pending.
Task exception was never retrieved
future: <Task finished coro=<main() done, defined at async.py:173> exception=BrokenProcessPool('A process in the process pool was terminated abruptly while the future was running or pending.',)>
Message.objects.filter(
Q(user_sender_id=token.user_id) |
Q(user_receiver_id=token.user_id)).order_by('user_sender', 'user_receiver').distinct('user_sender', 'user_receiver')