From 6fdff6989e6c3391861f2d0e9830164014f57674 Mon Sep 17 00:00:00 2001 From: Renat Akhmerov Date: Mon, 28 Apr 2014 22:00:08 +0700 Subject: [PATCH] Making workflow trace logging more consistent * Deleted a comma everywhere in workflow trace logging Change-Id: I98c6c96e283b08f076ddc4b9617548dad844dcad --- mistral/engine/abstract_engine.py | 6 +++--- mistral/engine/scalable/executor/server.py | 1 - 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/mistral/engine/abstract_engine.py b/mistral/engine/abstract_engine.py index 24be56027..d30d5390d 100644 --- a/mistral/engine/abstract_engine.py +++ b/mistral/engine/abstract_engine.py @@ -95,8 +95,8 @@ class AbstractEngine(object): #TODO(rakhmerov): validate state transition task = db_api.task_get(workbook_name, execution_id, task_id) - wf_trace_msg = "Task '%s', [%s -> %s" % (task['name'], - task['state'], state) + wf_trace_msg = "Task '%s' [%s -> %s" % \ + (task['name'], task['state'], state) wf_trace_msg += ']' if state == states.ERROR \ else ", result = %s]" % result @@ -119,7 +119,7 @@ class AbstractEngine(object): if execution['state'] != new_exec_state: wf_trace_msg = \ - "Execution '%s', [%s -> %s]" % \ + "Execution '%s' [%s -> %s]" % \ (execution_id, execution['state'], new_exec_state) WORKFLOW_TRACE.info(wf_trace_msg) diff --git a/mistral/engine/scalable/executor/server.py b/mistral/engine/scalable/executor/server.py index 5d351b472..2dad685f3 100644 --- a/mistral/engine/scalable/executor/server.py +++ b/mistral/engine/scalable/executor/server.py @@ -30,7 +30,6 @@ WORKFLOW_TRACE = logging.getLogger(cfg.CONF.workflow_trace_log_name) class Executor(object): - def __init__(self, transport=None): self.transport = engine.get_transport(transport) self.engine = client.EngineClient(self.transport)