aboutsummaryrefslogtreecommitdiffstats
path: root/python/external_deriv_marks.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/external_deriv_marks.py')
-rw-r--r--python/external_deriv_marks.py5
1 files changed, 3 insertions, 2 deletions
diff --git a/python/external_deriv_marks.py b/python/external_deriv_marks.py
index e6d2584d..aa012958 100644
--- a/python/external_deriv_marks.py
+++ b/python/external_deriv_marks.py
@@ -338,7 +338,7 @@ def get_box_dimension(l):
if __name__ == "__main__":
import argparse
import logging
- from serenitas.utils.db import dbconn
+ from serenitas.utils.db2 import dawn_pool
parser = argparse.ArgumentParser()
parser.add_argument(
@@ -370,7 +370,7 @@ if __name__ == "__main__":
if df.empty and cp == "CS":
df = globals()[f"{cp.lower()}_navs_old"](date, fund=fund)
logger.debug(df)
- with dbconn("dawndb") as conn:
+ with dawn_pool.connection() as conn:
with conn.cursor() as c:
for k, v in df[["local_nav", "base_nav", "ia"]].iterrows():
c.execute(
@@ -387,3 +387,4 @@ if __name__ == "__main__":
float(v.ia),
),
)
+ conn.commit()