def getInspectionData(**context):
    token = context.get("ti").xcom_pull(key="token")

    # mongo_conn = BaseHook.get_connection("mongo_conn")
    # mongo_uri = f"mongodb://{mongo_conn.host}:{mongo_conn.port}"
    # mongo_client = MongoClient(mongo_uri)
    # mongo_db = mongo_client[mongo_conn.schema]
    # workflow_collection = mongo_db['workflows']
    # workflow_records = mongo_db['workflowrecords']

    itp_response = requests.get(
        url=f"{dRoW_api_end_url}/api/module/document-export/airflow/workflow/6780da3a19a6ea5c197f5e8a?export_type=0",
        headers={
            "x-access-token": f"Bearer {token}",
            "ICWPxAccessKey": "5WSD21ICWP_[1AG:4UdI){n=b~"
        }
    )
    ITP_Data = json.loads(itp_response.text)
    risc_response = requests.get(
        url=f"{dRoW_api_end_url}/api/module/document-export/airflow/workflow/6732d16bf0fd5b8f573d79ef?export_type=0",
        headers={
            "x-access-token": f"Bearer {token}",
            "ICWPxAccessKey": "5WSD21ICWP_[1AG:4UdI){n=b~"
        }
    )
    RISC_Data = json.loads(risc_response.text)

    conn_string = getdrowPSQLConnectionString()
    db = create_engine(conn_string)
    conn = db.connect()

    with conn as conn:
        itp_df = pd.DataFrame()
        for x in ITP_Data:
            print("Data ITP:", x)
            df_nested_list = json_normalize(x['data'])
            df_nested_list['ITP ID'] = x['_id']
            itp_df = itp_df.append(df_nested_list)
        # print("ITP Dataframe:", itp_df.columns)

        df = pd.DataFrame()
        for x in RISC_Data:
            print("Data RISC:", x)
            df_nested_list = json_normalize(x['data'])
            df = df.append(df_nested_list)