diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/monitor.py | 28 |
1 files changed, 28 insertions, 0 deletions
diff --git a/python/monitor.py b/python/monitor.py new file mode 100644 index 00000000..1929cb35 --- /dev/null +++ b/python/monitor.py @@ -0,0 +1,28 @@ +import os +import time +import subprocess +import common +import datetime +from intex_scenarios import generate_scenarios + +Rpath = os.path.join(common.root, "code", "R") +logpath = os.path.join(common.root, "logs") +cusipsfile = os.path.join(common.root, "scripts", "cusips_to_price.txt") +scenariosfile = os.path.join(common.root, "scripts", "scenarios.txt") +args1 = ["Rscript", "--vanilla", os.path.join(Rpath, "build_portfolios.R")] +args2 = ["Rscript", "--vanilla", os.path.join(Rpath, "build_scenarios.R")] +while True: + workdate = str(datetime.date.today()) + if os.path.exists(cusipsfile): + with open(os.path.join(logpath, "build_portfolios.Rout"), "w") as fh: + p = subprocess.Popen(args1, stderr = fh) + if os.path.exists(scenariosfile): + with open(scenariosfile) as fh: + dealnames = [line.split("\t")[0] for line in fh.readline()] + with open(os.path.join(logpath, "build_scenarios.Rout"), "w") as fh: + p = subprocess.(args2, stderr = fh) + p.wait() + generate_scenarios(workdate, dealnames, common.conn.common.cursor) + time.sleep(3) +common.cursor.close() +common.conn.close() |