diff options
| -rw-r--r-- | python/process_queue.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index 7e8eb0cf..3ef14619 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -86,7 +86,8 @@ def bbg_process(conn, session, trade): principal_payment = currentface * trade['price'] / 100. with conn.cursor() as c: c.execute("UPDATE bonds SET principal_payment = %s, accrued_payment = %s " - "WHERE id = %s", (principal_payment, accrued_payment, trade['id'])) + "WHERE id = %s", (principal_payment, accrued_payment, trade['id'])) + conn.commit() if len(fields) > 2: #we don't have the data in the securities table sql_fields = ['identifier', 'cusip', 'isin', 'description', 'face_amount', 'maturity', 'floater', 'spread', 'coupon', 'frequency', |