diff --git a/bigframes/core/compile/polars/compiler.py b/bigframes/core/compile/polars/compiler.py index a70ea49752..e1531ee9e5 100644 --- a/bigframes/core/compile/polars/compiler.py +++ b/bigframes/core/compile/polars/compiler.py @@ -646,7 +646,7 @@ def _aggregate( def compile_explode(self, node: nodes.ExplodeNode): assert node.offsets_col is None df = self.compile_node(node.child) - cols = [pl.col(col.id.sql) for col in node.column_ids] + cols = [col.id.sql for col in node.column_ids] return df.explode(cols) @compile_node.register