1 files changed, 2 insertions, 2 deletions
diff --git a/python/quote_parsing/parse_emails.py b/python/quote_parsing/parse_emails.py
index 7a6f908f..9f10c222 100644
--- a/python/quote_parsing/parse_emails.py
+++ b/python/quote_parsing/parse_emails.py
@@ -794,10 +794,10 @@ def write_todb(swaption_stack, index_data, conn):
         sql.SQL(", ").join(sql.Identifier(c) for c in index_data.columns),
         sql.SQL(", ").join(sql.Placeholder() * len(index_data.columns)),
     )
-
+    cols = [sql.Identifier(e) for e in (*swaption_stack.columns, "ref_id")]
     sql_quotes = sql.SQL(
         "INSERT INTO swaption_quotes({}) VALUES %s ON CONFLICT DO NOTHING"
-    ).format(sql.SQL(", ").join(sql.Identifier(c) for c in swaption_stack.columns))
+    ).format(sql.SQL(", ").join(cols))
     index_data["expiry"] = pd.to_datetime(index_data.expiry)
     with conn.cursor() as c:
         for t in index_data.itertuples(index=False):