openstack/zaqar
Code Issues Proposed changes

In benchmark observer worker, include claimed messages when listing

Browse Source 
This a tiny change to make the observer behave more as you might
expect an auditing/diagnostic client to behave when obeserving
a task distribution queue.

Change-Id: Idcb8eb970c1f205b9fc7efdfeb860805b1a45640
This commit is contained in:
kgriffs 2014-09-03 16:14:37 -05:00
parent 97cf725bdd
commit 40aa3bfc01
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
zaqar/bench/observer.py
View File

@ -70,7 +70,8 @@ def observer(queues, stats, test_duration, limit):
try:
marktime.start('list_messages')
cursor = queue['q'].messages(limit=limit, marker=queue['m'])
cursor = queue['q'].messages(limit=limit, marker=queue['m'],
include_claimed=True)
total_elapsed += marktime.stop('list_messages').seconds
total_succeeded += 1