Code Review
/
integration
/
test.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Fix Flake8 errors
[integration/test.git]
/
tools
/
odl-mdsal-clustering-tests
/
clustering-performance-test
/
inventory_read_blaster.py
diff --git
a/tools/odl-mdsal-clustering-tests/clustering-performance-test/inventory_read_blaster.py
b/tools/odl-mdsal-clustering-tests/clustering-performance-test/inventory_read_blaster.py
index 87a19ebc85dc3c53907be59c332e1406866a180a..c1d48d2476985664eff0a78295456422a7e735f5 100755
(executable)
--- a/
tools/odl-mdsal-clustering-tests/clustering-performance-test/inventory_read_blaster.py
+++ b/
tools/odl-mdsal-clustering-tests/clustering-performance-test/inventory_read_blaster.py
@@
-67,7
+67,7
@@
def read(hosts, port, auth, datastore, print_lock, cycles, results_queue):
stats[r.status_code] = stats.get(r.status_code, 0) + 1
with print_lock:
stats[r.status_code] = stats.get(r.status_code, 0) + 1
with print_lock:
- print
' ', threading.current_thread().name, 'results:', stats
+ print
(' %s results: %s' % (threading.current_thread().name, stats))
results_queue.put(stats)
results_queue.put(stats)
@@
-118,6
+118,6
@@
if __name__ == "__main__":
# Aggregate the results
stats = functools.reduce(operator.add, map(collections.Counter, results.queue))
# Aggregate the results
stats = functools.reduce(operator.add, map(collections.Counter, results.queue))
- print
'\n*** Test summary:'
- print
' Elapsed time: %.2fs' % t.secs
- print
' HTTP[OK] results: %d\n' % stats[200]
+ print
('\n*** Test summary:')
+ print
(' Elapsed time: %.2fs' % t.secs)
+ print
(' HTTP[OK] results: %d\n' % stats[200])