@@ -12,7 +12,7 @@ def unpack_column_tokens(column_tokens: pd.Series, token_symbols: typing.List[st
1212 di [f'token_{ symbol } _weight' ].append (r [symbol .upper ()].weight )
1313 di [f'token_{ symbol } _denorm_weight' ].append (r [symbol .upper ()].denorm_weight )
1414 di [f'token_{ symbol } _balance' ].append (r [symbol .upper ()].balance )
15- return pd .DataFrame .from_dict (di )
15+ return pd .DataFrame .from_dict (di ). astype ( 'float64' )
1616
1717
1818def unpack_column_generated_fees (column_fees : pd .Series , token_symbols : typing .List [str ]) -> pd .DataFrame :
@@ -57,7 +57,7 @@ def unpack_column_spot_prices(df: pd.DataFrame) -> pd.DataFrame:
5757 di [f'token_{ symbol_low } _spot_price' ] = []
5858 for r in column_spot_prices :
5959 di [f'token_{ symbol_low } _spot_price' ].append (r [symbol ])
60- return pd .DataFrame .from_dict (di )
60+ return pd .DataFrame .from_dict (di ). astype ( 'float64' )
6161
6262
6363def assets_in_df (df : pd .DataFrame ) -> typing .List [str ]:
@@ -84,8 +84,9 @@ def post_processing(df: pd.DataFrame, include_spot_prices=False) -> pd.DataFrame
8484 unpacked_column_spot_prices = unpack_column_spot_prices (df )
8585 df = df .assign (** unpacked_column_spot_prices )
8686
87- # Convert change_datetime from str to datetime
87+ # Convert change_datetime from str to datetime, other columns to float64
8888 df ["change_datetime" ] = pd .to_datetime (df ["change_datetime" ], utc = True )
89+ df = df .astype ({"pool_shares" : "float64" , "swap_fee" : "float64" })
8990
9091 # Calculate token_{x}_value columns
9192 token_x_value = calc_token_x_value (df )
0 commit comments