Skip to content

Commit

Permalink
dynamic index size
Browse files Browse the repository at this point in the history
  • Loading branch information
pixelsoup42 committed Sep 10, 2023
1 parent bb0dc4a commit dad3b86
Showing 1 changed file with 7 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -361,6 +361,7 @@ def _transaction_balance(self, transaction: Namespace) -> Any:
def _make_balance_frame(self, transactions: pd.Series) -> pd.DataFrame:
balance = pd.DataFrame(
data=[self._transaction_balance(x) for x in transactions],
dtype=pd.Int64Dtype,
)
balance.columns = pd.MultiIndex.from_tuples(balance.columns)
balance.sort_index(axis=1, level=0, sort_remaining=True, inplace=True)
Expand Down Expand Up @@ -414,12 +415,15 @@ def make_transaction_frame(self) -> pd.DataFrame:
)
]
balance.drop(assets_to_drop, axis=1, inplace=True)

balance_column_index_length = len(balance.columns[0])
frame = pd.concat([timestamp, tx_hash, message], axis=1)
frame.columns = pd.MultiIndex.from_tuples(
[("metadata", c, "") for c in frame.columns]
[
("metadata", c) + (balance_column_index_length - 2) * ("",)
for c in frame.columns
]
)
frame = frame.merge(balance, left_index=True, right_index=True)
frame.drop_duplicates(inplace=True)
frame.sort_values(by=("metadata", "timestamp", ""), inplace=True)
frame.sort_values(by=frame.columns[1], inplace=True)
return frame

0 comments on commit dad3b86

Please sign in to comment.