cleaning up

rust/tests/dat.rs

@@ -35,7 +35,7 @@ async fn $test_name() -> TestResult {
     let root = Path::new("tests/data/dat-data/v0.0.2/reader_tests/generated").join(test_case);
     let actual_path = root.join(Path::new("delta"));
     let expected_path_root = root.join(Path::new("expected"));
-    let actual = open_table(&actual_path.to_str().unwrap()).await.unwrap();
+    let actual = open_table(&actual_path.to_str().unwrap()).await?;
     let max_verison = actual.version();
     for version in (0..=max_verison).rev() {
         let ctx: SessionContext = SessionContext::new();
@@ -47,15 +47,13 @@ async fn $test_name() -> TestResult {
         let expected_path = expected_path_root
             .join(Path::new(&vstring))
             .join(Path::new("table_content"));
-        // assert!(&actual_path.exists());
-        // assert!(&expected_path.exists());
         if !expected_path.exists(){
             dbg!("bang");
             continue;
         }
         let expected = ctx.read_parquet(expected_path.to_str().unwrap(), ParquetReadOptions::default()).await?;
-        let mut actual = open_table(&actual_path.to_str().unwrap()).await.unwrap();
-        actual.load_version(version).await.unwrap();
+        let mut actual = open_table(&actual_path.to_str().unwrap()).await?;
+        actual.load_version(version).await?;
         ctx.register_table("actual", Arc::new(actual))?;
         assert!(deltaeq(&ctx, "actual", expected).await);
     }