diff options
Diffstat (limited to 'python/task_server/globeop.py')
| -rw-r--r-- | python/task_server/globeop.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/python/task_server/globeop.py b/python/task_server/globeop.py index 251e378a..1aca3fdb 100644 --- a/python/task_server/globeop.py +++ b/python/task_server/globeop.py @@ -146,6 +146,14 @@ def download_data(workdate: datetime.date): def insert_todb(workdate: datetime.date): reports_dir = DAILY_DIR / str(workdate) / "Reports" + if not reports_dir.exists(): + reports_dir = ( + DAILY_DIR + / f"{workdate:%Y}" + / f"{workdate:%Y_%m}" + / str(workdate) + / "Reports" + ) engine = create_engine("postgresql://dawn_user@debian/dawndb") for report in ["Valuation", "Pnl", "CDS"]: fun = getattr(load_globeop_report, f"read_{report.lower()}_report") |