diff options
| -rw-r--r-- | python/insert_fx_id.py | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/python/insert_fx_id.py b/python/insert_fx_id.py index 53ede1a3..a6ab83a9 100644 --- a/python/insert_fx_id.py +++ b/python/insert_fx_id.py @@ -88,7 +88,9 @@ def read_MSCSNY(fund, workdate): "trade_date", "settle_date", ): - df[date_column] = pd.to_datetime(df[date_column], infer_datetime_format=True) + df[date_column] = pd.to_datetime( + df[date_column], infer_datetime_format=True + ).dt.date df[["buy_amount", "sell_amount"]] = df[["buy_amount", "sell_amount"]].apply( pd.to_numeric, errors="coerce" ) @@ -116,8 +118,8 @@ def main(workdate): & (dawn_trades["fund"] == fund_code) ] filters = { - "trade_date": pd.Timestamp(row.trade_date), - "settle_date": pd.Timestamp(row.settle_date), + "trade_date": row.trade_date, + "settle_date": row.settle_date, "buy_currency": row.buy_currency, "sell_currency": row.sell_currency, "buy_amount": row.buy_amount, |