We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e568adf commit c867097Copy full SHA for c867097
python/cudf_polars/cudf_polars/dsl/ir.py
@@ -2359,7 +2359,7 @@ def do_evaluate(
2359
join_fn, left_policy, right_policy = cls._joiners(how)
2360
if right_policy is None:
2361
# Semi join
2362
- lg = join_fn(left_on.table, right_on.table, null_equality)
+ lg = join_fn(left_on.table, right_on.table, null_equality, stream)
2363
table = plc.copying.gather(left.table, lg, left_policy, stream=stream)
2364
result = DataFrame.from_table(
2365
table, left.column_names, left.dtypes, stream=stream
0 commit comments