Skip to content

Commit 58f4bd5

Browse files
committed
Refactor projection initialization in PyDataFrame to improve clarity
1 parent 9054e17 commit 58f4bd5

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

src/dataframe.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,6 +59,7 @@ use crate::{
5959
expr::{sort_expr::PySortExpr, PyExpr},
6060
};
6161

62+
#[allow(clippy::manual_c_str_literals)]
6263
static ARROW_STREAM_NAME: &CStr =
6364
unsafe { CStr::from_bytes_with_nul_unchecked(b"arrow_array_stream\0") };
6465

@@ -946,7 +947,7 @@ impl PyDataFrame {
946947
let stream = spawn_stream(py, async move { df.execute_stream().await })?;
947948

948949
let mut schema: Schema = self.df.schema().to_owned().into();
949-
let mut projection: Option<SchemaRef> = Some(Arc::new(schema.clone()));
950+
let mut projection: Option<SchemaRef> = None;
950951

951952
if let Some(schema_capsule) = requested_schema {
952953
validate_pycapsule(&schema_capsule, "arrow_schema")?;

0 commit comments

Comments
 (0)