style

Eventual-Inc · Oct 2, 2024 · 0252bbb · 0252bbb
1 parent 61cb9ba
commit 0252bbb
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/daft-local-execution/src/sources/scan_task.rs b/src/daft-local-execution/src/sources/scan_task.rs
@@ -294,8 +294,7 @@ async fn stream_scan_task(
         }
         #[cfg(feature = "python")]
         FileFormatConfig::PythonFunction => {
-            let iter =
-                daft_micropartition::python::read_pyfunc_into_table_iter(&scan_task)?;
+            let iter = daft_micropartition::python::read_pyfunc_into_table_iter(&scan_task)?;
             let stream = futures::stream::iter(iter.map(|r| r.map_err(|e| e.into())));
             Box::pin(stream) as Pin<Box<dyn Stream<Item = DaftResult<Table>> + Send>>
         }