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 9fcf5ff commit c5aaa11Copy full SHA for c5aaa11
src/snowflake/snowpark/mock/_plan.py
@@ -1495,8 +1495,8 @@ def aggregate_by_groups(cur_group: TableEmulator):
1495
if isinstance(source_plan, Project):
1496
return TableEmulator(ColumnEmulator(col) for col in source_plan.project_list)
1497
if isinstance(source_plan, Join):
1498
- L_expr_to_alias = {}
1499
- R_expr_to_alias = {}
+ L_expr_to_alias = getattr(source_plan.left, "expr_to_alias", {})
+ R_expr_to_alias = getattr(source_plan.right, "expr_to_alias", {})
1500
left = execute_mock_plan(source_plan.left, L_expr_to_alias).reset_index(
1501
drop=True
1502
)
0 commit comments