114 lines
4.3 KiB
Python
Executable File
114 lines
4.3 KiB
Python
Executable File
#!/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'
|
|
author_name = 'DB Datasets CI'
|
|
author_account_id = 9578
|
|
upstream_user = 'jenkins'
|
|
upstream_author_name = "Jenkins"
|
|
upstream_author_account_id = 3
|
|
|
|
# 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 = []
|
|
upstream_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
|
|
last_upstream_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 (not last_message and
|
|
message['author']['_account_id'] == author_account_id):
|
|
last_message = message['message']
|
|
if (not last_upstream_message and
|
|
message['author']['_account_id'] ==
|
|
upstream_author_account_id):
|
|
last_upstream_message = message['message']
|
|
|
|
if (last_upstream_message and
|
|
'Merge Failed.' in last_upstream_message.split('\n')[2]):
|
|
upstream_merge_failures.append({
|
|
'change_id': change_id,
|
|
'updated': change['updated'],
|
|
'change': change,
|
|
'last_upstream_message': last_upstream_message,
|
|
})
|
|
elif not last_message:
|
|
# turbo-hister hasn't commented on this patchset
|
|
no_votes.append({
|
|
'change_id': change_id,
|
|
'updated': change['updated'],
|
|
'change': change,
|
|
'last_upstream_message': last_upstream_message,
|
|
})
|
|
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,
|
|
'last_upstream_message': last_upstream_message,
|
|
})
|
|
elif 'Database migration testing failed' in last_message:
|
|
negative_votes.append({
|
|
'change_id': change_id,
|
|
'updated': change['updated'],
|
|
'change': change,
|
|
'last_upstream_message': last_upstream_message,
|
|
})
|
|
else:
|
|
unknown.append({
|
|
'change_id': change_id,
|
|
'updated': change['updated'],
|
|
'change': change,
|
|
'last_upstream_message': last_upstream_message,
|
|
})
|
|
|
|
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)
|
|
print "=" * 20 + (" Changes with merge failures upstream (%d) "
|
|
% len(upstream_merge_failures)) + "=" * 20
|
|
print_enqueues(upstream_merge_failures)
|