Function send_websocket_update

core/utils.py:476–503

Sends a WebSocket group message. In gevent-patched uWSGI workers, asyncio event loop creation fails because monkey-patching removes select.epoll. For those contexts a synchronous Redis path is used instead, matching the channels_redis 4.x wire format. Celery prefork workers ma

(group_name, event_type, data, collect_garbage=False)

def send_websocket_update(group_name, event_type, data, collect_garbage=False):
    """
    Sends a WebSocket group message.

    In gevent-patched uWSGI workers, asyncio event loop creation fails because
    monkey-patching removes select.epoll. For those contexts a synchronous Redis
    path is used instead, matching the channels_redis 4.x wire format.

    Celery prefork workers may inherit gevent monkey-patching without a running
    gevent hub; in that case gevent.spawn would never execute, so delivery is
    synchronous via Redis instead.
    """
    message = {'type': event_type, 'data': data}

    if _should_use_sync_websocket_send():
        _gevent_ws_send(group_name, message)
    elif _is_gevent_monkey_patched():
        import gevent
        gevent.spawn(_gevent_ws_send, group_name, message)
    else:
        # Not gevent-patched (plain Celery, tests) — use asyncio channel layer
        try:
            async_to_sync(get_channel_layer().group_send)(group_name, message)
        except Exception as e:
            logger.warning(f"Failed to send WebSocket update: {e}")

    if collect_garbage:
        gc.collect()

def send_websocket_event(event, success, data):
    """Acquire a lock to prevent concurrent task execution."""