Make task execution logging more readable and informative

* Changed a debug log statement more readable for tasks
* Minor style changes

Change-Id: I841c15230fe2bc1e605a985bb1b9cd6131ac795c
This commit is contained in:
Renat Akhmerov 2018-09-19 15:21:40 +07:00
parent 8720a2711b
commit c802ad2851
2 changed files with 14 additions and 7 deletions

View File

@ -404,10 +404,12 @@ class RegularTask(Task):
self.notify(None, self.task_ex.state)
LOG.debug(
'Starting task [workflow=%s, task=%s, init_state=%s]',
self.wf_ex.name,
'Starting task [name=%s, init_state=%s, workflow_name=%s,'
' execution_id=%s]',
self.task_spec.get_name(),
self.task_ex.state
self.task_ex.state,
self.wf_ex.name,
self.wf_ex.id
)
self._before_task_start()

View File

@ -25,7 +25,8 @@ LOG = logging.getLogger(__name__)
def register_standard_workflows(run_in_tx=True):
LOG.debug("Registering standard workflows")
LOG.debug("Registering standard workflows...")
workflow_paths = utils.get_file_list(STD_WF_PATH)
for wf_path in workflow_paths:
@ -45,17 +46,21 @@ def _clear_system_workflow_db():
def sync_db():
LOG.debug("Syncing db")
LOG.debug("Syncing db...")
with db_api.transaction():
_clear_system_workflow_db()
register_standard_workflows(run_in_tx=False)
def create_workflows(definition, scope='private', is_system=False,
run_in_tx=True, namespace=''):
LOG.debug("Creating workflows")
LOG.debug("Creating workflows...")
wf_list_spec = spec_parser.get_workflow_list_spec_from_yaml(
definition, validate=True
definition,
validate=True
)
db_wfs = []