Skip to content

Commit 6f77f17

Browse files
committed
fix(ir): handle renaming for scalar operations
1 parent c6a6c56 commit 6f77f17

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

ibis/expr/types/generic.py

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1247,9 +1247,15 @@ def as_table(self) -> ir.Table:
12471247
op = self.op()
12481248
table = find_first_base_table(op)
12491249
if table is not None:
1250-
return table.to_expr().aggregate([self])
1250+
return table.to_expr().aggregate(**{self.get_name(): self})
12511251
else:
1252-
return ops.DummyTable(values=(op,)).to_expr()
1252+
if isinstance(op, ops.Alias):
1253+
value = op
1254+
assert value.name == self.get_name()
1255+
else:
1256+
value = ops.Alias(op, self.get_name())
1257+
1258+
return ops.DummyTable(values=(value,)).to_expr()
12531259

12541260
def __deferred_repr__(self):
12551261
return f"<scalar[{self.type()}]>"

0 commit comments

Comments
 (0)