diff --git a/xorbits_sql/executor.py b/xorbits_sql/executor.py index c45f2cd..227fa79 100644 --- a/xorbits_sql/executor.py +++ b/xorbits_sql/executor.py @@ -398,7 +398,9 @@ def aggregate( for p in post_processes: p(result) locs = [ - i for i, n in enumerate(result.dtypes.index) if not n.startswith("__") + i + for i, n in enumerate(result.dtypes.index) + if not n.startswith("__op_") and not n.startswith("__agg_") ] result = result.iloc[:, locs]