diff options
Diffstat (limited to 'python/http-server.py')
| -rw-r--r-- | python/http-server.py | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/python/http-server.py b/python/http-server.py index 5e2311a2..c74d701a 100644 --- a/python/http-server.py +++ b/python/http-server.py @@ -37,10 +37,11 @@ class MyHandler(BaseHTTPRequestHandler): d = parse_qsl(self.rfile.read(length).decode('utf-8')) self.log_message("%s" , json.dumps(d)) workdate = str(datetime.date.today()) + pipe = self.server.queue.pipeline() for dealname, reinvflag in d: - self.server.queue.rpush("tasks", - json.dumps(("build_portfolio", - [workdate, dealname, reinvflag]))) + pipe.rpush("tasks", json.dumps(("build_portfolio", + [workdate, dealname, reinvflag]))) + pipe.execute() self.send_response(200) self.end_headers() |