diff options
| -rw-r--r-- | .gitignore | 1 | ||||
| -rw-r--r-- | python/Dawn/config_qa.ini | 9 | ||||
| -rw-r--r-- | python/download_markit_quotes.py | 2 | ||||
| -rw-r--r-- | python/position.py | 2 | ||||
| -rw-r--r-- | python/process_queue.py | 4 | ||||
| -rw-r--r-- | python/task_server/globeop.py | 4 | ||||
| -rw-r--r-- | python/task_server/insert_tranche_quotes.py | 2 |
7 files changed, 8 insertions, 16 deletions
@@ -12,6 +12,7 @@ *.Rhistory *.pyc config.ini +config_qa.ini config.py python/.ipynb_checkpoints python/secret.json diff --git a/python/Dawn/config_qa.ini b/python/Dawn/config_qa.ini deleted file mode 100644 index a5a14482..00000000 --- a/python/Dawn/config_qa.ini +++ /dev/null @@ -1,9 +0,0 @@ -SQLALCHEMY_DATABASE_URI = 'postgresql://qa:Serenitas2@debian/dawndb' -SQLALCHEMY_TRACK_MODIFICATIONS = False -TICKETS_FOLDER = '/home/share/Daily/tickets' -CP_FOLDER = '/home/share/Daily/counterparties' -SECRET_KEY = 'papa' -LOGFILE = '/home/share/CorpCDOs/logs/dawn.log' -DEBUG = False -SEND_FILE_MAX_AGE_DEFAULT = 60 -SCHEMA = 'qa'
\ No newline at end of file diff --git a/python/download_markit_quotes.py b/python/download_markit_quotes.py index 41e83905..42ca98b4 100644 --- a/python/download_markit_quotes.py +++ b/python/download_markit_quotes.py @@ -13,7 +13,7 @@ from task_server.insert_tranche_quotes import insert_quotes import logging import sys -logging.basicConfig(filename='/home/share/CorpCDOs/logs/download_tranche_quotes.log', +logging.basicConfig(filename='/home/serenitas/CorpCDOs/logs/download_tranche_quotes.log', level=logging.INFO, format='%(asctime)s %(message)s') diff --git a/python/position.py b/python/position.py index 90f23fcd..9af6d5c9 100644 --- a/python/position.py +++ b/python/position.py @@ -37,7 +37,7 @@ def get_list_range(engine, begin, end, asset_class=None): def backpopulate_marks(begin_str='2015-01-15', end_str='2015-07-15'): pattern = re.compile("\d{4}-\d{2}-\d{2}") - list_of_daily_folder = (fullpath for (fullpath, _, _) in os.walk('/home/share/Daily') + list_of_daily_folder = (fullpath for (fullpath, _, _) in os.walk('/home/serenitas/Daily') if pattern.match(os.path.basename(fullpath))) list_of_bdays = bdate_range(start=begin_str, end=end_str) for path in list_of_daily_folder: diff --git a/python/process_queue.py b/python/process_queue.py index 2b99831c..cae2d369 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -326,13 +326,13 @@ def upload_file(timestamp, queue_name='bond_trades'): ftp.cwd('incoming') filename = get_filename(timestamp, queue_name) cmd = 'STOR {0}'.format(filename) - with open(os.path.join('/home/share/Daily', str(timestamp.date()), filename), 'rb') as fh: + with open(os.path.join('/home/serenitas/Daily', str(timestamp.date()), filename), 'rb') as fh: ftp.storbinary(cmd, fh) def write_buffer(buf, queue_name='bond_trades'): timestamp = pd.datetime.now() filename = get_filename(timestamp, queue_name) - with open(os.path.join('/home/share/Daily', str(timestamp.date()), filename), 'wb') as fh: + with open(os.path.join('/home/serenitas/Daily', str(timestamp.date()), filename), 'wb') as fh: fh.write(buf) return timestamp diff --git a/python/task_server/globeop.py b/python/task_server/globeop.py index 84c3230b..03750ca4 100644 --- a/python/task_server/globeop.py +++ b/python/task_server/globeop.py @@ -18,9 +18,9 @@ except ImportError: pass
if os.name =='nt':
- root = "//WDsentinel/share/Daily"
+ root = "//diskstation/Daily"
elif os.name == 'posix':
- root = '/home/share/Daily'
+ root = '/home/serenitas/Daily'
def get_ped(s):
regex = re.search("PED=([^.]+)", s)
diff --git a/python/task_server/insert_tranche_quotes.py b/python/task_server/insert_tranche_quotes.py index 58a6e207..02d93190 100644 --- a/python/task_server/insert_tranche_quotes.py +++ b/python/task_server/insert_tranche_quotes.py @@ -36,7 +36,7 @@ runningdict2 = {0: 500, 3:500, 7:500, 10:100, 15:100, 30:100} def insert_quotes(year=2016, quote_dir=None):
if not quote_dir:
- root_dir = '/home/share/CorpCDOs'
+ root_dir = '/home/serenitas/CorpCDOs'
quote_dir = os.path.join(root_dir, 'Tranche_data', 'Quotes')
quotefiles = [f for f in os.listdir(quote_dir) if f.endswith('csv')]
for quotefile in quotefiles:
|