-
Couldn't load subscription status.
- Fork 1.7k
Closed
Labels
bugSomething isn't workingSomething isn't working
Description
Describe the bug
I'm getting errors in the form of DataFusionError::External(External(External(External(External(External(xyz)))) when throwing them from https://docs.rs/datafusion/latest/datafusion/physical_plan/trait.ExecutionPlan.html#tymethod.execute
To Reproduce
Implement a TableProvider that throws an error and call it
fn execute(
&self,
partition: usize,
_context: Arc<TaskContext>,
) -> datafusion::common::Result<SendableRecordBatchStream> {
return Err(DataFusionError::Execution(
format!("error"),
));
}
Expected behavior
I'd expect the External(External(External(External(External flattened to just one External
Additional context
- This seems to be a regression as it wasn't happening in e.g., v42
- Similar fixes have been done for other parts of the code fix: Avoid re-wrapping planning errors Err(DataFusionError::Plan) for use in plan_datafusion_err #14000
Metadata
Metadata
Assignees
Labels
bugSomething isn't workingSomething isn't working