code: def get_db_data(engine, input_query):
      """
  
      :param engine:
      :param input_query:
      :return:
      """
      logging.info("querying db...")
      try:
          df = pd.DataFrame.pg_copy_from(input_query, engine)
      except SQLAlchemyError as e:
          logging.error(
              "PG: could not get the resulting table. Please check your input_query. "
              + e
          )
          exit(1)
      return df
  
file_path: aequitas/src/aequitas_cli/utils/io.py
imports: import pandas
  import ohio.ext.pandas
  import logging
  from datetime import datetime
  from os import path
  from sys import exit
  from sqlalchemy import create_engine
  from sqlalchemy.exc import SQLAlchemyError
  from xhtml2pdf import pisa
label_desc: Use image node_id 1 for calling a global function with example usage: get_db_data(engine, input_query) and returns: df