from airflow.dag_processing.processor import DagFileProcessor
    from airflow.models.dag import DagModel
    functions: list[Callable] = [
        DagFileProcessor.update_import_errors,
        DagModel.get_paused_dag_ids,
        DagFileProcessorManager.clear_nonexistent_import_errors,
        XCom.get_value,
        XCom.get_one,
        XCom.get_many,
        XCom.clear,
        Variable.set,
        Variable.update,
        Variable.delete,
    ]
    return {f"{func.__module__}.{func.__name__}": func for func in functions}
def internal_airflow_api(body: dict[str, Any]) -> APIResponse:
    """Handler for Internal API /internal_api/v1/rpcapi endpoint."""
    log.debug("Got request")
    json_rpc = body.get("jsonrpc")
    if json_rpc != "2.0":