Merge "Add in tool to suggest rechecks for bad votes"
diff --git a/tools/zuul_enqueue.py b/tools/zuul_enqueue.py
new file mode 100755
index 0000000..2b31567
--- /dev/null
+++ b/tools/zuul_enqueue.py
@@ -0,0 +1,87 @@
+#!/usr/bin/python
+# This tool is useful to query gerrit for negative or missing votes left by
+# a user. It may require tweaking for different failure messages etc.
+
+import json
+import requests
+import traceback
+
+# Set the user to watch
+user = 'turbo-hipster'
+
+# Grab a list of missing or negative reviews for a user:
+url = ("https://review.openstack.org/changes/?q=status:open "
+ "project:openstack/nova NOT label:Verified>=0,%s "
+ "branch:master&o=CURRENT_REVISION&o=MESSAGES" % user)
+
+print "Grabbing reviews from %s" % url
+r = requests.get(url)
+
+no_votes = []
+negative_votes = []
+merge_failures = []
+unknown = []
+
+for change in json.loads(r.text[5:]):
+ try:
+ patchset = change['revisions'][change['current_revision']]['_number']
+ change_id = str(change['_number']) + ',' + str(patchset)
+ last_message = None
+ for message in sorted(change['messages'],
+ key=lambda k: (k['_revision_number'],
+ k['date']), reverse=True):
+ if message['_revision_number'] < patchset:
+ # Finished looking at all the messages on this patchset
+ break
+ if message['author']['name'] == user:
+ last_message = message['message']
+ break
+
+ if not last_message:
+ # turbo-hister hasn't commented on this patchset
+ no_votes.append({
+ 'change_id': change_id,
+ 'updated': change['updated'],
+ 'change': change
+ })
+ elif ('This change was unable to be automatically merged with the '
+ 'current state of the repository.' in last_message):
+ merge_failures.append({
+ 'change_id': change_id,
+ 'updated': change['updated'],
+ 'change': change
+ })
+ elif 'Database migration testing failed' in last_message:
+ negative_votes.append({
+ 'change_id': change_id,
+ 'updated': change['updated'],
+ 'change': change
+ })
+ else:
+ unknown.append({
+ 'change_id': change_id,
+ 'updated': change['updated'],
+ 'change': change
+ })
+
+ except Exception:
+ print "Something failed.. Here is the change..."
+ print change
+ traceback.print_exc()
+
+
+def print_enqueues(changes):
+ for change in sorted(changes, key=lambda k: k['updated'], reverse=True):
+ print ("zuul enqueue --trigger gerrit --pipeline check "
+ "--project openstack/nova --change %s" % (change['change_id']))
+
+print "=" * 20 + (" Changes with no votes (%d) " % len(no_votes)) + "=" * 20
+print_enqueues(no_votes)
+print ("=" * 20 + (" Changes with negative votes (%d) " % len(negative_votes))
+ + "=" * 20)
+print_enqueues(negative_votes)
+print ("=" * 20 + (" Changes with merge failure (%d) " % len(merge_failures)) +
+ "=" * 20)
+print_enqueues(merge_failures)
+print "=" * 20 + (" Others in this query (%d) " % len(unknown)) + "=" * 20
+print_enqueues(unknown)