openstack
/
rally
Code Issues Proposed changes

print completed workloads progress while running 

Expect to see the completed and uncompeted workloads count while rally
is running.
Change-Id: I3a7cc7e279dc8aa2d78d93697de68f2cf8a62404
This commit is contained in:
chenhb 2020-07-15 20:04:10 +08:00
parent 695f5ecbab
commit 112f9ca3bb
1 changed files with 19 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
rally/task/engine.py
View File

@ -448,10 +448,13 @@ class TaskEngine(object):
corresponding benchmark test launches
"""
self.task.update_status(consts.TaskStatus.RUNNING)
self.task_workloads_count = 0
self.task_workload_index = 0
for subtask in self.config.subtasks:
self.task_workloads_count += len(subtask["workloads"])
try:
for subtask in self.config.subtasks:
self._run_subtask(subtask)
for index, subtask in enumerate(self.config.subtasks, 1):
self._run_subtask(subtask, index)
except TaskAborted:
LOG.info("Received aborting signal.")
self.task.update_status(consts.TaskStatus.ABORTED)
@ -460,15 +463,26 @@ class TaskEngine(object):
self.task["uuid"]) != consts.TaskStatus.ABORTED:
self.task.update_status(consts.TaskStatus.FINISHED)
def _run_subtask(self, subtask):
def _run_subtask(self, subtask, subtask_position):
subtask_obj = self.task.add_subtask(title=subtask["title"],
description=subtask["description"],
contexts=subtask["contexts"])
try:
# TODO(astudenov): add subtask context here
for workload in subtask["workloads"]:
workloads_count = len(subtask["workloads"])
for index, workload in enumerate(subtask["workloads"], 1):
self._run_workload(subtask_obj, workload)
self.task_workload_index += 1
LOG.info("Finished workload %(index)d/%(count)d"
" of subtask %(subtask)d "
" (completed %(t_index)d of %(t_count)d "
"in general)." % {
"index": index,
"count": workloads_count,
"subtask": subtask_position,
"t_index": self.task_workload_index,
"t_count": self.task_workloads_count})
except TaskAborted:
subtask_obj.update_status(consts.SubtaskStatus.ABORTED)
raise