We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 26422bd commit 9157154Copy full SHA for 9157154
1 file changed
crates/core/src/sql/logical.rs
@@ -203,12 +203,6 @@ impl PyLogicalPlan {
203
py: Python<'py>,
204
ctx: Option<PySessionContext>,
205
) -> PyDataFusionResult<Bound<'py, PyBytes>> {
206
- // When the caller supplies a session, route through its
207
- // installed logical codec so user FFI codecs registered via
208
- // `with_logical_extension_codec` see the encode path.
209
- // Otherwise fall back to a default-inner `PythonLogicalCodec`
210
- // — Python scalar UDFs still inline via `DFPYUDF1`, but
211
- // non-Python UDFs hit the default codec only.
212
let default_codec;
213
let codec: &dyn datafusion_proto::logical_plan::LogicalExtensionCodec = match ctx {
214
Some(ref ctx) => ctx.logical_codec().as_ref(),
0 commit comments