Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
ritchie46 committed Apr 29, 2024
1 parent c1286b1 commit 21b8416
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
1 change: 1 addition & 0 deletions crates/polars-lazy/src/frame/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1196,6 +1196,7 @@ impl LazyFrame {
.right_on(right_on)
.how(args.how)
.validate(args.validation)
.coalesce(args.coalesce)
.join_nulls(args.join_nulls);

if let Some(suffix) = args.suffix {
Expand Down
3 changes: 1 addition & 2 deletions crates/polars-plan/src/logical_plan/schema.rs
Original file line number Diff line number Diff line change
Expand Up @@ -313,12 +313,11 @@ pub(crate) fn det_join_schema(
new_schema.with_column(field.name, field.dtype);
arena.clear();
}
let coalesces_join_keys = options.args.coalesce.coalesce(&options.args.how);
// Except in asof joins. Asof joins are not equi-joins
// so the columns that are joined on, may have different
// values so if the right has a different name, it is added to the schema
#[cfg(feature = "asof_join")]
if !coalesces_join_keys {
if !options.args.coalesce.coalesce(&options.args.how) {
for (left_on, right_on) in left_on.iter().zip(right_on) {
let field_left =
left_on.to_field_amortized(schema_left, Context::Default, &mut arena)?;
Expand Down

0 comments on commit 21b8416

Please sign in to comment.