https://github.com/apache/airflow/blob/main/airflow/dag_processing/manager.py#L773
#
#
from __future__ import annotations
import functools
import json
import logging
from typing import Any, Callable
from flask import Response
from airflow.api_connexion.types import APIResponse
from airflow.serialization.serialized_objects import BaseSerialization
log = logging.getLogger(__name__)
@functools.lru_cache()
def _initialize_map() -> dict[str, Callable]:
    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,
    ]
    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":