Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
11-29-2023 02:35 AM
I've managed to do it like this
qry = spark.sql(f"DESCRIBE history <table_name> limit 1").collect()
current_version = int(qry[0][0])
prev_version = current_version - 1
Then do an except statement between the versions.
