Function _dispatch_system_event_integrations

core/utils.py:791–824

Run Connect subscriptions and plugin event hooks without blocking the caller. On gevent uWSGI workers, dispatch runs in a spawned greenlet so slow webhooks, scripts, or plugin handlers cannot stall live-proxy teardown or streaming paths. Celery prefork workers (gevent patched but n

(
    event_type, channel_id=None, channel_name=None, **details
)

def _dispatch_system_event_integrations(
    event_type, channel_id=None, channel_name=None, **details
):
    """
    Run Connect subscriptions and plugin event hooks without blocking the caller.

    On gevent uWSGI workers, dispatch runs in a spawned greenlet so slow webhooks,
    scripts, or plugin handlers cannot stall live-proxy teardown or streaming paths.
    Celery prefork workers (gevent patched but no hub) run synchronously instead.
    """

    def _run():
        try:
            dispatch_event_system(
                event_type,
                channel_id=channel_id,
                channel_name=channel_name,
                **details,
            )
        except Exception as e:
            logger.error(
                "Failed to dispatch Connect/plugin handlers for event %s: %s",
                event_type,
                e,
            )

    if _should_use_sync_websocket_send():
        _run()
    elif _is_gevent_monkey_patched():
        import gevent

        gevent.spawn(_run)
    else:
        _run()


def log_system_event(event_type, channel_id=None, channel_name=None, **details):