AiDOPWarehouse/doc/plan/sql/uat-data/_tmp_queue_snapshot.py

from apply_sql_file import connect

conn = connect()
try:
    with conn.cursor() as cur:
        cur.execute(
            """
            SELECT id, tenant_id, module_code, status, current_stage, heartbeat_at
            FROM ado_module_dashboard_rebuild_job
            WHERE status IN ('QUEUED','RUNNING','FAILED') AND id>=9113
            ORDER BY id
            """
        )
        for row in cur.fetchall():
            print(row)
finally:
    conn.close()