1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
#!/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)
|
