Skip to content

Commit b1c638c

Browse files
devin-petersohnkunalgosar
authored andcommitted
Fix items() (#6)
* Fix items * Removing debug code
1 parent 5a5dcff commit b1c638c

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

python/ray/dataframe/dataframe.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1748,9 +1748,10 @@ def items(self):
17481748
for part in self._row_partitions])
17491749

17501750
def concat_iters(iterables):
1751-
for partitions in zip(*iterables):
1752-
series = pd.concat([_series for _, _series in partitions])
1751+
for partitions in enumerate(zip(*iterables)):
1752+
series = pd.concat([_series for _, _series in partitions[1]])
17531753
series.index = self.index
1754+
series.name = list(self.columns)[partitions[0]]
17541755
yield (series.name, series)
17551756

17561757
return concat_iters(iters)

0 commit comments

Comments
 (0)