1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
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()
|
