Skip to content

Commit 3bb0464

Browse files
committed
sync polars compiler with main
1 parent af90071 commit 3bb0464

File tree

1 file changed

+2
-10
lines changed

1 file changed

+2
-10
lines changed

bigframes/core/compile/polars/compiler.py

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -724,22 +724,14 @@ def _ordered_join(
724724
]
725725
)
726726
if how != "cross":
727-
# Note: join_nulls renamed to nulls_equal for polars 1.24
728-
polars_version = tuple(
729-
int(part) for part in pl.__version__.split(".") if part.isnumeric()
730-
)
731-
if polars_version >= (1, 24, 0):
732-
join_kwargs = {"nulls_equal": join_nulls}
733-
else:
734-
join_kwargs = {"join_nulls": join_nulls}
735-
736727
joined = left.join(
737728
right,
738729
how=how,
739730
left_on=left_on,
740731
right_on=right_on,
732+
# Note: join_nulls renamed to nulls_equal for polars 1.24
733+
join_nulls=join_nulls, # type: ignore
741734
coalesce=False,
742-
**join_kwargs, # type: ignore
743735
)
744736
else:
745737
joined = left.join(right, how=how, coalesce=False)

0 commit comments

Comments
 (0)