@@ -53,22 +53,22 @@ def test_spark_reads_table_after_rewrite_manifests(session_catalog: Catalog, spa
5353 assert len ([m for m in snapshot .manifests (table .io ) if m .content == ManifestContent .DATA ]) == 1
5454
5555 # Spark must read the rewritten table with the same data
56- spark_rows = spark .table (f"integration. { identifier } " ).collect ()
56+ spark_rows = spark .table (f"{ identifier } " ).collect ()
5757 assert sorted (row .id for row in spark_rows ) == list (range (1 , 10 ))
5858
5959 # Spark must see the replace snapshot and the preserved data files
60- snapshots = spark .sql (f"SELECT operation FROM integration. { identifier } .snapshots ORDER BY committed_at" ).collect ()
60+ snapshots = spark .sql (f"SELECT operation FROM { identifier } .snapshots ORDER BY committed_at" ).collect ()
6161 assert [row .operation for row in snapshots ] == ["append" , "append" , "append" , "replace" ]
6262
63- files = spark .sql (f"SELECT file_path FROM integration. { identifier } .files" ).collect ()
63+ files = spark .sql (f"SELECT file_path FROM { identifier } .files" ).collect ()
6464 assert len (files ) == 3
6565
6666 # Spark sees the same manifest consolidation
67- manifests = spark .sql (f"SELECT path FROM integration. { identifier } .manifests" ).collect ()
67+ manifests = spark .sql (f"SELECT path FROM { identifier } .manifests" ).collect ()
6868 assert len (manifests ) == 1
6969
7070 # time travel to the pre-rewrite snapshot still works from Spark
7171 previous_snapshot_id = snapshot .parent_snapshot_id
7272 assert previous_snapshot_id is not None
73- previous_rows = spark .sql (f"SELECT id FROM integration. { identifier } VERSION AS OF { previous_snapshot_id } " ).collect ()
73+ previous_rows = spark .sql (f"SELECT id FROM { identifier } VERSION AS OF { previous_snapshot_id } " ).collect ()
7474 assert sorted (row .id for row in previous_rows ) == list (range (1 , 10 ))
0 commit comments