Function _do

core/utils.py:891–895

()

def _send_async(channel_layer, group, message):
    """Send a channel layer group message without blocking the gevent hub."""
    def _do():
        try:
            async_to_sync(channel_layer.group_send)(group, message)
        except Exception as e:
            logger.warning(f"Failed WebSocket group_send to '{group}': {e}")

    try:
        import gevent.monkey