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

    records = get_workflow_records(token, WORKFLOW_ID)
    print(f"Total records fetched from main workflow: {len(records) if records else 0}")

    if not records:
        print("No records found in main workflow.")
        return

    output_rows = [extract_output_row(record) for record in records]

    print("\n===== OUTPUT ROWS TO INSERT (PAYMENT STATISTICS) =====")
    print(json.dumps(output_rows[:1], indent=2, default=str))

    df = pd.DataFrame(output_rows)

    engine = get_postgres_connection()

    # COMMENTED OUT FOR NOW
    # df.to_sql(
    #     TARGET_TABLE,
    #     engine,
    #     if_exists="replace",
    #     index=False
    # )

    print(f"[SKIPPED DB INSERT] Prepared {len(df)} rows for {TARGET_TABLE}")