diff options
Diffstat (limited to 'python/calibrate_swaption.py')
| -rw-r--r-- | python/calibrate_swaption.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/python/calibrate_swaption.py b/python/calibrate_swaption.py index 740c1be1..e9e005f3 100644 --- a/python/calibrate_swaption.py +++ b/python/calibrate_swaption.py @@ -44,6 +44,7 @@ def get_data_latest(conn): ] *= 100 if not df.empty: df.quotedate = df.quotedate.dt.tz_convert("America/New_York") + conn.commit() return df @@ -133,6 +134,7 @@ def calibrate(index_type=None, series=None, date=None, nproc=4, latest=False): to_insert = [[a] + b for a, b in zip(df.quote_id, r)] with serenitasdb.cursor() as c: c.executemany(sql_str, to_insert) + serenitasdb.commit() if __name__ == "__main__": |