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()