aboutsummaryrefslogtreecommitdiffstats
path: root/python/tasks.py
blob: 8f646fdbec672bfe7176f4ce5e1aebba6f491e3d (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
import subprocess
from intex.intex_scenarios import generate_scenarios
import os

def build_portfolio(workdate, dealname, reinvflag):
    rpath = os.path.join(os.environ['CODE_DIR'], "R")
    logpath = os.path.join(os.environ['LOG_DIR'])
    args = ["Rscript", "--vanilla", os.path.join(rpath, "build_portfolios.R"), \
            workdate, dealname + "," + reinvflag]
    with open(os.path.join(logpath, "build_portfolios.Rout"), "w") as fh:
        subprocess.call(args, stderr=subprocess.STDOUT, stdout=fh, env=os.environ,
                        cwd=rpath)

def build_scenarios(workdate, dealname, reinvflag):
    rpath = os.path.join(os.environ['CODE_DIR'], "R")
    logpath = os.path.join(os.environ['LOG_DIR'])
    args = ["Rscript", "--vanilla", os.path.join(rpath, "build_scenarios.R"), \
            workdate, dealname + "," + reinvflag]
    with open(os.path.join(logpath, "build_scenarios.Rout"), "w") as fh:
        subprocess.call(args, stderr=subprocess.STDOUT, stdout=fh, env=os.environ,
                        cwd=rpath)