Re: Django Channels 2 Group_send to channel layer causes runtime error: "got Future attached to a different loop"

how did you test it ? did you use a specific cmd to excute ?

Le vendredi 16 février 2018 à 22:08:55 UTC+1, Luke Hebert a écrit :

Trying to call the "alert_receive" consumer method

import json

from channels.consumer import SyncConsumer

from channels.exceptions import StopConsumer

from asgiref.sync import async_to_sync

from channels.layers import get_channel_layer

class ClientAlertPtrConsumer(SyncConsumer):
    def websocket_connect(self, event):
        async_to_sync(self.channel_layer.group_add)("AlertReceivers", self.channel_name)
        self.send({
                "type": "websocket.accept",
            })
   
    def websocket_receive(self, event):
        content = json.dumps("received")
        async_to_sync(self.channel_layer.group_send)("AlertReceivers", {"type":"alert.receive"})
        
    def websocket_disconnect(self, event):
        async_to_sync(self.channel_layer.group_discard)("AlertReceivers", self.channel_name)
        raise StopConsumer
       
    def alert_receive(self, event):                 # Get a message on the alert.receive type
        content = json.dumps("Group send working")
        self.send({
            "type":"websocket.send",                # then send a message out on websocket protocol to whatever the 'self' channel is.
            "text":content,
            })

from outside this consumer class using the approach in documentation like this

from asgiref.sync import async_to_sync
from channels.layers import get_channel_layer
channel_layer = get_channel_layer()

async_to_sync(channel_layer.group_send)("AlertReceivers", {'type':"alert.receive"})

and getting the following traceback having to do with the concurrent.futures module:

Traceback (most recent call last):

  File "/usr/lib/python3.5/code.py", line 91, in runcode

    exec(code, self.locals)

  File "<console>", line 1, in <module>

  File "/usr/local/lib/python3.5/dist-packages/asgiref/sync.py", line 49, in __call__

    return call_result.result()

  File "/usr/lib/python3.5/concurrent/futures/_base.py", line 398, in result

    return self.__get_result()

  File "/usr/lib/python3.5/concurrent/futures/_base.py", line 357, in __get_result

    raise self._exception

  File "/usr/local/lib/python3.5/dist-packages/asgiref/sync.py", line 63, in main_wrap

    result = await self.awaitable(*args, **kwargs)

  File "/usr/local/lib/python3.5/dist-packages/channels_redis/core.py", line 313, in group_send

    pool = await self.connection(self.consistent_hash(group))

  File "/usr/local/lib/python3.5/dist-packages/channels_redis/core.py", line 377, in connection

    self.pools[index] = await aioredis.create_redis_pool(**self.hosts[index])

  File "/usr/local/lib/python3.5/dist-packages/aioredis/commands/__init__.py", line 197, in create_redis_pool

    loop=loop)

  File "/usr/local/lib/python3.5/dist-packages/aioredis/pool.py", line 59, in create_pool

    await pool.wait_closed()

  File "/usr/local/lib/python3.5/dist-packages/aioredis/pool.py", line 177, in wait_closed

    await asyncio.shield(self._close_waiter, loop=self._loop)

  File "/usr/lib/python3.5/asyncio/futures.py", line 361, in __iter__

    yield self  # This tells Task to wait for completion.

RuntimeError: Task <Task pending coro=<AsyncToSync.main_wrap() running at /usr/local/lib/python3.5/dist-packages/asgiref/sync.py:63> cb=[_run_until_complete_cb() at /usr/lib/python3.5/asyncio/base_events.py:164]> got Future <Future pending> attached to a different loop

Note that the 

async_to_sync(channel_layer.group_send)("AlertReceivers", {'type':"alert.receive"})

within the websocket_receive method of the consumer class works well, sending the event out onto redis-based channel layers and then sending json encoded "Group send working" WS message to client. 

--
You received this message because you are subscribed to the Google Groups "Django users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to django-users+unsubscribe@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/django-users/e53418ed-daea-41fc-88e5-cdf5602d5859n%40googlegroups.com.