Function _get_clickhouse_client

api/experimentation/services.py:102–112

Build a clickhouse-driver client for the experimentation event store. The database is taken from the DSN path, so queries can reference the `events` table unqualified. Connect and query timeouts are bounded unless the DSN overrides them.

()

@lru_cache(maxsize=1)
def _get_clickhouse_client() -> Client:
    """Build a clickhouse-driver client for the experimentation event store.

    The database is taken from the DSN path, so queries can reference the
    `events` table unqualified. Connect and query timeouts are bounded unless the
    DSN overrides them.
    """
    host, kwargs = parse_url(settings.EXPERIMENTATION_CLICKHOUSE_URL)
    kwargs.setdefault("connect_timeout", CLICKHOUSE_CONNECT_TIMEOUT_SECONDS)
    kwargs.setdefault("send_receive_timeout", CLICKHOUSE_QUERY_TIMEOUT_SECONDS)
    return Client(host, **kwargs)


def get_unique_event_names(environment_key: str) -> list[str]: