diff options
Diffstat (limited to 'python/process_queue.py')
| -rw-r--r-- | python/process_queue.py | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index 1e8caa9b..51427d17 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -635,12 +635,14 @@ def get_bbg_data( placeholders = ",".join(["%s"] * len(sql_fields)) columns = ",".join(sql_fields) - sqlstr = f"INSERT INTO securities({columns}) VALUES({placeholders})" + sqlstr = ( + f"INSERT INTO securities({columns}) VALUES({placeholders}) " + "ON CONFLICT (identifier) DO NOTHING" + ) isfloater = bbg_data["FLOATER"] == "Y" pay_delay = bbg_data.get("MTG_PAY_DELAY", 0) day_count = bbg_data.get("DAY_CNT_DES") - m = re.match("[^(\s]+", day_count) - if m: + if m := re.match("[^(\s]+", day_count): day_count = m.group(0) if isinstance(pay_delay, str): pay_delay = int(pay_delay.split(" ")[0]) |