diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/client.py | 8 | ||||
| -rw-r--r-- | python/master.py | 8 | ||||
| -rw-r--r-- | python/tasks.py | 8 |
3 files changed, 24 insertions, 0 deletions
diff --git a/python/client.py b/python/client.py new file mode 100644 index 00000000..5f7ec6d6 --- /dev/null +++ b/python/client.py @@ -0,0 +1,8 @@ +import redis +import tasks +from pickle import loads + +q = redis.Redis() +while True: + f, args = loads(q.blpop("tasks")[1]) + getattr(tasks, f)(*args) diff --git a/python/master.py b/python/master.py new file mode 100644 index 00000000..e1e488d2 --- /dev/null +++ b/python/master.py @@ -0,0 +1,8 @@ +import redis +from pickle import dumps +import datetime + +q = redis.Redis() +workdate = str(datetime.date.today()) +for dealname in ['ares26', 'carlg131', 'cata131']: + q.rpush("tasks", dumps(("generate_scenarios", [workdate, dealname]))) diff --git a/python/tasks.py b/python/tasks.py new file mode 100644 index 00000000..e842343c --- /dev/null +++ b/python/tasks.py @@ -0,0 +1,8 @@ +import subprocess +from intex_scenarios import generate_scenarios + +def build_portfolio(dealname): + pass + +def build_scenario(dealname): + pass |