aboutsummaryrefslogtreecommitdiffstats
path: root/python/task_server/globeop.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/task_server/globeop.py')
-rw-r--r--python/task_server/globeop.py10
1 files changed, 6 insertions, 4 deletions
diff --git a/python/task_server/globeop.py b/python/task_server/globeop.py
index e123933f..6676c721 100644
--- a/python/task_server/globeop.py
+++ b/python/task_server/globeop.py
@@ -2,13 +2,15 @@ import os
import os.path
from ftplib import FTP
import gnupg
-from . import config
+from task_server import config
import re
import logging
import shutil
import pandas as pd
from sqlalchemy import create_engine
+logger = logging.getLogger(__name__)
+
try:
import pandas as pd
from pandas.tseries.offsets import BDay
@@ -77,7 +79,7 @@ def download_data(workdate):
available_files.append(sorted(cdsfiles, key=run_date, reverse=True)[0])
if not available_files:
- logging.error("no file available for date: %s" % str(workdate))
+ logger.error("no file available for date: %s" % str(workdate))
return
reports_dir = os.path.join(root, str(workdate), "Reports")
@@ -87,7 +89,7 @@ def download_data(workdate):
for filename in available_files:
with open(os.path.join(reports_dir, filename), "wb") as fh:
ftp.retrbinary('RETR ' + filename, fh.write)
- logging.info("downloaded {0}".format(filename))
+ logger.info("downloaded {0}".format(filename))
gpg = get_gpg()
for filename in available_files:
@@ -116,4 +118,4 @@ def upload_data(engine, workdate):
ftp = get_ftp('incoming')
with open(fullpath, "rb") as fh:
ftp.storbinary('STOR ' + filename, fh)
- logging.info("upload done")
+ logger.info("upload done")