diff options
| -rw-r--r-- | python/citco_ops/utils.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/python/citco_ops/utils.py b/python/citco_ops/utils.py index 6e71ef9f..c07f8cb9 100644 --- a/python/citco_ops/utils.py +++ b/python/citco_ops/utils.py @@ -93,10 +93,12 @@ class CitcoSubmission(Deal, deal_type=None, table_name="citco_submission"): for row in cls._insert_queue: if row[1] == "instrument": serenitas_id = row[3] + sql_str = f"UPDATE {instrument_table(serenitas_id)} SET committed=True, status='Acknowledged' WHERE dealid=%s" c.execute( - f"UPDATE {instrument_table(serenitas_id)} SET committed=True AND status='Acknowledged' WHERE dealid=%s", + sql_str, (serenitas_id,), ) + cls._conn.commit() @classmethod def commit(cls): |