diff options
Diffstat (limited to 'python/report_ops/admin.py')
| -rw-r--r-- | python/report_ops/admin.py | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/python/report_ops/admin.py b/python/report_ops/admin.py index 8bb1cb53..74c49b83 100644 --- a/python/report_ops/admin.py +++ b/python/report_ops/admin.py @@ -71,14 +71,18 @@ class CitcoReport: df.columns = df.columns.str.replace(" ", "_") df["period_end_date"] = self.date df["knowledge_date"] = self.knowledge_date + df["fund"] = self.fund return df def to_db(self): df = self.to_df() with self._conn.cursor() as c: c.execute( - f"DELETE FROM {self.table} WHERE period_end_date= %s", - (self.date,), + f"DELETE FROM {self.table} WHERE period_end_date=%s AND fund=%s", + ( + self.date, + self.fund, + ), ) self._conn.commit() if "strategy" in df.columns: |