diff --git a/test/test_iceberg.py b/test/test_iceberg.py index 3d8847a..1bc4e25 100644 --- a/test/test_iceberg.py +++ b/test/test_iceberg.py @@ -46,9 +46,13 @@ def test_diff_two_same_branches(spark, lfs_client, lakefs_repo): def test_delete_on_dev_and_merge(spark, lfs_client, lakefs_repo): lfs_client.branches.create_branch(lakefs_repo, BranchCreation(name="test1", source="main")) + print("1") + spark.sql("SELECT * FROM lakefs.test1.company.workers").show() spark.sql("DELETE FROM lakefs.test1.company.workers WHERE id = 6") lfs_client.commits.commit(lakefs_repo, "test1", CommitCreation(message="delete one row")) lfs_client.refs.merge_into_branch(lakefs_repo, "test1", "main") + print("2") + spark.sql("SELECT * FROM lakefs.main.company.workers").show() df_main = spark.read.table("lakefs.main.company.workers") df_dev = spark.read.table("lakefs.test1.company.workers") assert (df_main.schema == df_dev.schema) and (df_main.collect() == df_dev.collect()), "main and test1 tables should be equal"