Function _try_wasm_duckdb

marimo/_sql/utils.py:66–93

(
    method_name: str,
    query: str,
    connection: Any,
    glbls: dict[str, Any],
    *trailing_args: Any,
)

def _try_wasm_duckdb(
    method_name: str,
    query: str,
    connection: Any,
    glbls: dict[str, Any],
    *trailing_args: Any,
) -> object:
    import duckdb

    if connection is duckdb:
        original = getattr(duckdb, method_name)
        args: tuple[Any, ...] = (query, *trailing_args)
        query_arg_index = 0
    else:
        original = getattr(type(connection), method_name)
        args = (connection, query, *trailing_args)
        query_arg_index = 1

    result = try_run_duckdb_sql_with_wasm_patch(
        original,
        args,
        {},
        query_arg_index=query_arg_index,
        query_kwarg_names=("query",),
        eval_globals=glbls,
        eval_locals=glbls,
    )
    return _NO_WASM_DUCKDB_RESULT if result is None else result.value


def wrapped_sql(