diff options
Diffstat (limited to 'python/report_ops/custodians.py')
| -rw-r--r-- | python/report_ops/custodians.py | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/python/report_ops/custodians.py b/python/report_ops/custodians.py index 9d1913cc..95c0befa 100644 --- a/python/report_ops/custodians.py +++ b/python/report_ops/custodians.py @@ -40,11 +40,10 @@ def upload_to_custodian(account, trade_date, conn, upload, em): ), ) for row in c: - old_trade = None _service = {"BBH": "BRINKER", "UMB": "UMB"} custodian = Service[_service[account]] - c.execute("SELECT * FROM bond_csv_upload WHERE allocationid=%s", (row.id,)) - if old_trade := c.fetchone(): + d.execute("SELECT * FROM bond_csv_upload WHERE allocationid=%s", (row.id,)) + if old_trade := d.fetchone(): try: d.execute( _csv_query, |