diff --git a/src/daft-scan/src/scan_task_iters/retrieve_parquet_metadata.rs b/src/daft-scan/src/scan_task_iters/retrieve_parquet_metadata.rs
index 717f9b0a80..a2b2ad97a8 100644
--- a/src/daft-scan/src/scan_task_iters/retrieve_parquet_metadata.rs
+++ b/src/daft-scan/src/scan_task_iters/retrieve_parquet_metadata.rs
@@ -117,7 +117,7 @@ impl<T: Fetchable> State<T> {
         match &self {
             Self::ConstructingWindow(_) => {
                 let next_fetchable = inputs.next();
-                self.handle_next_fetchable(next_fetchable, max_num_fetchables_per_window)
+                self.handle_constructing_window(next_fetchable, max_num_fetchables_per_window)
             }
             Self::WindowFinalized(_) => self.handle_window_finalized(),
             Self::WindowFetched(_) => self.handle_window_fetched(),
@@ -133,7 +133,7 @@ impl<T: Fetchable> State<T> {
         matches!(self, Self::Exhausted)
     }
 
-    fn handle_next_fetchable(
+    fn handle_constructing_window(
         mut self,
         next_fetchable: Option<DaftResult<T>>,
         max_num_fetchables_per_window: &usize,
@@ -141,7 +141,9 @@ impl<T: Fetchable> State<T> {
         let accumulating_window = if let Self::ConstructingWindow(accumulating_window) = &mut self {
             accumulating_window
         } else {
-            unreachable!("handle_next_fetchable must be called from the ConstructingWindow state")
+            unreachable!(
+                "handle_constructing_window must be called from the ConstructingWindow state"
+            )
         };
 
         if let Some(fetchable) = next_fetchable {