You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: crates/polars-plan/src/dsl/plan.rs
+4-1Lines changed: 4 additions & 1 deletion
Original file line number
Diff line number
Diff line change
@@ -319,6 +319,7 @@ impl DslPlan {
319
319
reader.read_exact(&mut schema_hash).map_err(
320
320
|e| polars_err!(ComputeError:"failed to read incoming DSL_SCHEMA_HASH: {e}"),
321
321
)?;
322
+
322
323
let incoming_hash = SchemaHash::new(&schema_hash).ok_or_else(
323
324
|| polars_err!(ComputeError:"failed to read incoming DSL schema hash, not a valid hex string")
324
325
)?;
@@ -329,7 +330,9 @@ impl DslPlan {
329
330
);
330
331
}
331
332
332
-
if incoming_hash != DSL_SCHEMA_HASH{
333
+
if std::env::var("POLARS_SKIP_DSL_HASH_VERIFICATION").as_deref() != Ok("1")
334
+
&& incoming_hash != DSL_SCHEMA_HASH
335
+
{
333
336
polars_bail!(ComputeError:
334
337
"deserialization failed\n\ngiven DSL_SCHEMA_HASH: {incoming_hash} is not compatible with this Polars version which uses DSL_SCHEMA_HASH: {DSL_SCHEMA_HASH}\n{}",
335
338
"error: can't deserialize DSL with incompatible schema"
0 commit comments