diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/task_runner.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/python/task_runner.py b/python/task_runner.py index 44d152b3..5fcf8070 100644 --- a/python/task_runner.py +++ b/python/task_runner.py @@ -1,10 +1,10 @@ import logging -import tasks from systemd.daemon import notify from systemd import journal from db import dbconn from common import get_redis_queue +from tasks import Rpc def run(): ET = dbconn('etdb') @@ -13,7 +13,7 @@ def run(): while True: rpc = Rpc.from_json(q.blpop("tasks")[1].decode('utf-8')) - journal.send("Running '{}'".format(rpc.fun), ARGS=dumps(rpc.args)) + journal.send("Running '{}'".format(rpc.fun), ARGS=rpc.args) if rpc.fun == 'generate_scenarios': rpc.args += [ET] rpc() |