assertions on table version being accessed

rust/tests/dat.rs

@@ -16,7 +16,7 @@ async fn deltaeq(ctx: &SessionContext, delta_ctx_name: &str, expected: DataFrame
         false
     }
 }
-#[derive(Deserialize)]
+#[derive(Deserialize, Debug)]
 #[allow(dead_code)]
 struct TableVersionMetadata {
     version: i64,
@@ -48,12 +48,16 @@ async fn $test_name() -> TestResult {
             .join(Path::new(&vstring))
             .join(Path::new("table_content"));
         if !expected_path.exists(){
-            dbg!("bang");
             continue;
         }
+        let expected_metadata_path = expected_path_root.join(Path::new(&vstring)).join(Path::new("table_version_metadata.json"));
+        let expected_metadata_rdr = std::fs::File::open(expected_metadata_path.to_str().unwrap())?;
+
+        let expected_metadata: TableVersionMetadata = serde_json::from_reader(expected_metadata_rdr)?;
         let expected = ctx.read_parquet(expected_path.to_str().unwrap(), ParquetReadOptions::default()).await?;
         let mut actual = open_table(&actual_path.to_str().unwrap()).await?;
         actual.load_version(version).await?;
+        assert!(expected_metadata.version == actual.version());
         ctx.register_table("actual", Arc::new(actual))?;
         assert!(deltaeq(&ctx, "actual", expected).await);
     }