diff options
Diffstat (limited to 'python/collateral_calc.py')
| -rw-r--r-- | python/collateral_calc.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/python/collateral_calc.py b/python/collateral_calc.py index 601c6a88..9a566fa6 100644 --- a/python/collateral_calc.py +++ b/python/collateral_calc.py @@ -10,6 +10,7 @@ from time import sleep from pandas.tseries.offsets import BDay from paramiko import Transport, SFTPClient from download_emails import GmailMessage +from sqlalchemy.exc import IntegrityError DAILY_DIR = Path(os.environ["DAILY_DIR"]) logging.basicConfig(filename=os.path.join(os.getenv("LOG_DIR"), @@ -177,7 +178,10 @@ def sg_collateral(d): df_margin = df_margin.rename(columns={'SG IMR': 'amount', 'Currency': 'currency'}) df_margin['date'] = d - df_margin.to_sql("fcm_im", dbengine("dawndb"), if_exists='append', index=False) + try: + df_margin.to_sql("fcm_im", dbengine("dawndb"), if_exists='append', index=False) + except IntegrityError: + pass return df |