Skip to content

Commit 8f6aa7d

Browse files
LiaCastanedaclaude
andcommitted
fix example and test compile errors
- Remove undefined lambdas_params variable from json_shredding.rs example - Import Poll::Ready and Poll::Pending in coop.rs test (pre-existing missing import) Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
1 parent bb6d47f commit 8f6aa7d

2 files changed

Lines changed: 1 addition & 2 deletions

File tree

datafusion-examples/examples/data_io/json_shredding.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -330,7 +330,6 @@ impl ShreddedJsonRewriter {
330330
if let Some(column) = func.args()[1]
331331
.as_any()
332332
.downcast_ref::<expressions::Column>()
333-
.filter(|col| !lambdas_params.contains(col.name()))
334333
{
335334
let column_name = column.name();
336335
// Check if there's a flat column with underscore prefix

datafusion/core/tests/execution/coop.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ use std::error::Error;
5959
use std::fmt::Formatter;
6060
use std::ops::Range;
6161
use std::sync::Arc;
62-
use std::task::Poll;
62+
use std::task::Poll::{self, Pending, Ready};
6363
use std::time::Duration;
6464
use tokio::runtime::{Handle, Runtime};
6565
use tokio::select;

0 commit comments

Comments
 (0)