diff --git a/src/daft-core/src/array/ops/cast.rs b/src/daft-core/src/array/ops/cast.rs index 27a445d17b..a9b9b8c552 100644 --- a/src/daft-core/src/array/ops/cast.rs +++ b/src/daft-core/src/array/ops/cast.rs @@ -719,8 +719,6 @@ fn extract_python_like_to_fixed_size_list< child_dtype: &DataType, list_size: usize, ) -> DaftResult { - use std::sync::Arc; - let (values_vec, _, _, _) = extract_python_to_vec::(py, python_objects, child_dtype, None, Some(list_size), None)?; @@ -754,8 +752,6 @@ fn extract_python_like_to_list< python_objects: &PythonArray, child_dtype: &DataType, ) -> DaftResult { - use std::sync::Arc; - let (values_vec, offsets, _, _) = extract_python_to_vec::(py, python_objects, child_dtype, None, None, None)?; @@ -889,8 +885,6 @@ fn extract_python_like_to_tensor_array< dtype: &DataType, child_dtype: &DataType, ) -> DaftResult { - use std::sync::Arc; - let (data, offsets, shapes, shape_offsets) = extract_python_to_vec::( py, python_objects, diff --git a/src/daft-csv/src/read.rs b/src/daft-csv/src/read.rs index 626f5582d6..97c8cf7afb 100644 --- a/src/daft-csv/src/read.rs +++ b/src/daft-csv/src/read.rs @@ -31,8 +31,8 @@ use tokio::{ }; use tokio_util::io::StreamReader; +use crate::ArrowSnafu; use crate::{metadata::read_csv_schema_single, CsvConvertOptions, CsvParseOptions, CsvReadOptions}; -use crate::{schema, ArrowSnafu}; use daft_compression::CompressionCodec; use daft_decoding::deserialize::deserialize_column; diff --git a/src/daft-table/src/lib.rs b/src/daft-table/src/lib.rs index 8fd66a75e4..bbeb4da365 100644 --- a/src/daft-table/src/lib.rs +++ b/src/daft-table/src/lib.rs @@ -74,7 +74,7 @@ impl Table { pub fn new_unchecked>(schema: S, columns: Vec) -> Self { Table { schema: schema.into(), - columns: columns, + columns, } }