1 files changed, 3 insertions, 5 deletions
diff --git a/python/task_server/globeop.py b/python/task_server/globeop.py
index 908035a6..8d4334e9 100644
--- a/python/task_server/globeop.py
+++ b/python/task_server/globeop.py
@@ -17,8 +17,6 @@ try:
 except ImportError:
     pass
 
-root = os.getenv("DAILY_DIR")
-
 def get_ped(s):
     regex = re.search("PED=([^.]+)", s)
     if regex:
@@ -82,7 +80,7 @@ def download_data(workdate):
         logger.error("no file available for date: %s" % str(workdate))
         return
 
-    reports_dir = os.path.join(root, str(workdate), "Reports")
+    reports_dir = os.path.join(os.environ['DAILY_DIR'], str(workdate), "Reports")
     if not os.path.exists(reports_dir):
         os.makedirs(reports_dir)
 
@@ -115,7 +113,7 @@ def upload_bond_marks(engine, workdate):
     df.rename(columns = {'identifier': 'IDENTIFIER',
                          'price': 'Price'}, inplace=True)
     filename = 'securitiesNpv{0:%Y%m%d_%H%M%S}.csv'.format(workdate)
-    fullpath = os.path.join(root, str(workdate.date()), filename)
+    fullpath = os.path.join(os.environ['DAILY_DIR'], str(workdate.date()), filename)
     df.to_csv(fullpath, index=False)
     ftp = get_ftp('incoming')
     with open(fullpath, "rb") as fh:
@@ -127,7 +125,7 @@ def upload_cds_marks(engine, workdate):
 (a.clean_nav+a.accrued)  AS "NPV" from list_abscds_marks(%s) a
 JOIN cds USING (security_id)""", engine, params = (workdate.date(),))
     filename = 'otcNpv{0:%Y%m%d}.csv'.format(workdate)
-    fullpath = os.path.join(root, str(workdate.date()), filename)
+    fullpath = os.path.join(os.environ['DAILY_DIR'], str(workdate.date()), filename)
     df.to_csv(fullpath, index=False)
     ftp = get_ftp('incoming')
     with open(fullpath, "rb") as fh: