diff --git a/python/ray/dataframe/dataframe.py b/python/ray/dataframe/dataframe.py index a069d1c24..3253cd0a1 100644 --- a/python/ray/dataframe/dataframe.py +++ b/python/ray/dataframe/dataframe.py @@ -3266,7 +3266,7 @@ class DataFrame(object): columns=columns, index=index) else: - columns = self.columns[key] + columns = self._col_metadata[key].index indices_for_rows = [self.columns.index(new_col) for new_col in columns]