add unit tests and small fixes

crates/deltalake-core/src/table/mod.rs

@@ -8,6 +8,7 @@ use std::io::{BufRead, BufReader, Cursor};
 use std::sync::Arc;
 use std::{cmp::max, cmp::Ordering, collections::HashSet};
 
+use bytes::Bytes;
 use chrono::{DateTime, Utc};
 use futures::StreamExt;
 use lazy_static::lazy_static;

python/tests/test_table_read.py

@@ -9,7 +9,7 @@
 from packaging import version
 
 from deltalake._util import encode_partition_value
-from deltalake.exceptions import DeltaProtocolError
+from deltalake.exceptions import DeltaError, DeltaProtocolError
 from deltalake.table import ProtocolVersions
 from deltalake.writer import write_deltalake
 
@@ -497,12 +497,20 @@ def test_writer_fails_on_protocol():
 
 @pytest.mark.parametrize("version, expected", [(2, (5, 3))])
 def test_peek_next_commit(version, expected):
-    table_path = "../rust/tests/data/simple_table"
+    table_path = "../crates/deltalake-core/tests/data/simple_table"
     dt = DeltaTable(table_path)
     actions, current_version = dt.peek_next_commit(version=version)
     assert (len(actions), current_version) == expected
 
 
+def test_delta_log_not_found():
+    table_path = "../crates/deltalake-core/tests/data/simple_table"
+    dt = DeltaTable(table_path)
+    with pytest.raises(DeltaError) as e:
+        _, _ = dt.peek_next_commit(version=-2)
+    assert f"Delta log not found for table version:" in str(e)
+
+
 class ExcPassThroughThread(Thread):
     """Wrapper around `threading.Thread` that propagates exceptions."""