fix: pass ending_timestamp correctly

ion-elgreco · ion-elgreco · commit 0d533fc8e5ea · 2024-11-24T17:56:52.000Z
diff --git a/python/src/lib.rs b/python/src/lib.rs
@@ -697,7 +697,7 @@ impl RawDeltaTable {
             let ending_ts = DateTime::<Utc>::from_str(&et)
                 .map_err(|pe| PyValueError::new_err(pe.to_string()))?
                 .to_utc();
-            cdf_read = cdf_read.with_starting_timestamp(ending_ts);
+            cdf_read = cdf_read.with_ending_timestamp(ending_ts);
         }
 
         if let Some(columns) = columns {

Original file line number	Diff line number	Diff line change
`@@ -697,7 +697,7 @@ impl RawDeltaTable {`
`697`	`697`	`let ending_ts = DateTime::<Utc>::from_str(&et)`
`698`	`698`	`.map_err(\|pe\| PyValueError::new_err(pe.to_string()))?`
`699`	`699`	`.to_utc();`
`700`		`- cdf_read = cdf_read.with_starting_timestamp(ending_ts);`
	`700`	`+ cdf_read = cdf_read.with_ending_timestamp(ending_ts);`
`701`	`701`	`}`
`702`	`702`
`703`	`703`	`if let Some(columns) = columns {`