#
#
from __future__ import annotations
import functools
import json
import logging
from typing import TYPE_CHECKING, Any, Callable
from flask import Response
from airflow.jobs.job import Job, most_recent_job
from airflow.serialization.serialized_objects import BaseSerialization
from airflow.utils.session import create_session
if TYPE_CHECKING:
    from airflow.api_connexion.types import APIResponse
log = logging.getLogger(__name__)
@functools.lru_cache
def _initialize_map() -> dict[str, Callable]: