diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/report_ops/custodians.py | 15 |
1 files changed, 13 insertions, 2 deletions
diff --git a/python/report_ops/custodians.py b/python/report_ops/custodians.py index c9728055..cbf5c274 100644 --- a/python/report_ops/custodians.py +++ b/python/report_ops/custodians.py @@ -31,8 +31,10 @@ def upload_to_custodian(account, trade_date, upload, em): if any( [ old_row.identifier != row.identifier, - abs(old_row.principal_payment - row.principal_payment) > 1e-2, - abs(old_row.accrued_payment, row.accrued_payment) > 1e-2, + abs(float(old_row.principal_payment) - row.principal_payment) + > 1e-2, + abs(float(old_row.accrued_payment) - row.accrued_payment) + > 1e-2, ] ): old_trade = BondDeal.from_dict( @@ -51,6 +53,15 @@ def upload_to_custodian(account, trade_date, upload, em): else: continue else: + d.execute( + "INSERT INTO bond_csv_upload (allocationid, identifier, principal_payment, accrued_payment) VALUES (%s, %s, %s, %s)", + ( + row.id, + row.identifier, + row.principal_payment, + row.accrued_payment, + ), + ) trade = BondDeal.from_dict(**row._asdict(), scaled=True) custodian.push_trade(trade, "NEW") if not custodian.staging_queue: |