From 0252bbb763c219b506441d030d741f7325893d45 Mon Sep 17 00:00:00 2001 From: Colin Ho Date: Wed, 2 Oct 2024 10:10:50 -0700 Subject: [PATCH] style --- src/daft-local-execution/src/sources/scan_task.rs | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/daft-local-execution/src/sources/scan_task.rs b/src/daft-local-execution/src/sources/scan_task.rs index bd39d1aab5..58ca336b94 100644 --- 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> + Send>> }