code: def __call__(self, data: Dict, response: Response):
      if self.token and data["token"] != self.token:
          response.status_code = status.HTTP_401_UNAUTHORIZED
          return {
              "status": "failure",
              "reason": "Unauthorized request to the database.",
          }
  
      with Session(engine) as session:
          ele = self.models[data["cls_name"]].parse_raw(data["data"])
          session.add(ele)
          session.commit()
          session.refresh(ele)
          return ele
  
imports: import functools
  import json
  import pathlib
  from typing import Any, Dict, Generic, List, Type, TypeVar
  from fastapi import Response, status
  from fastapi.encoders import jsonable_encoder
  from lightning_utilities.core.imports import RequirementCache
  from pydantic import BaseModel, parse_obj_as
  from lightning.app.utilities.app_helpers import Logger
  from lightning.app.utilities.imports import _is_sqlmodel_available
label_desc: Use image node_id 2 for calling the _Insert obj's underlying member method code with example usage: obj.__call__(data, response) and returns: dict, ele