diff options
| -rw-r--r-- | python/load_globeop_report.py | 6 | ||||
| -rw-r--r-- | python/task_server/globeop.py | 5 |
2 files changed, 5 insertions, 6 deletions
diff --git a/python/load_globeop_report.py b/python/load_globeop_report.py index 60cf1ab6..f2ee406d 100644 --- a/python/load_globeop_report.py +++ b/python/load_globeop_report.py @@ -4,7 +4,6 @@ import pandas as pd from itertools import chain from dates import bus_day from db import dbengine -import task_server.globeop as globeop import datetime def get_globs(fname, years=['2013', '2014', '2015', '2016', '2017']): @@ -53,11 +52,6 @@ def read_pnl_report(f): df.columns = df.columns.str.lower().str.replace(" ", "") return df -def back_fill(start_date = datetime.date(2017,7,20)): - date_rng = pd.date_range(start = start_date, end = datetime.date.today(), freq='B') - for date in date_rng: - globeop.insert_todb(date.date()) - def pnl_reports(): df = {} for f in chain.from_iterable(get_globs('Pnl*')): diff --git a/python/task_server/globeop.py b/python/task_server/globeop.py index 24f205bd..d33f5189 100644 --- a/python/task_server/globeop.py +++ b/python/task_server/globeop.py @@ -164,3 +164,8 @@ JOIN cds USING (security_id)""", engine, params = (workdate.date(),)) def upload_data(engine, workdate):
upload_bond_marks(engine, workdate)
upload_cds_marks(engine, workdate)
+
+def back_fill(start_date=pd.datetime(2017,7,20)):
+ date_rng = pd.date_range(start=start_date, end=pd.Timestamp.today(), freq='B')
+ for date in date_rng:
+ insert_todb(date.date())
|