aboutsummaryrefslogtreecommitdiff
path: root/rt_update_tasks.py
diff options
context:
space:
mode:
authorcpettet <rush@wikimedia.org>2014-12-16 16:03:11 -0600
committercpettet <rush@wikimedia.org>2014-12-16 16:03:11 -0600
commit39d05f179c749aa14cdf9c7fc5e0c95efb5a29da (patch)
tree633b5e4a6c255a7a668ac7e11a7ebffad7d32065 /rt_update_tasks.py
parenta339253851065809235d3b1dcd9e6eb315e58152 (diff)
rt cleanup and user updates for header and comments
Diffstat (limited to 'rt_update_tasks.py')
-rwxr-xr-xrt_update_tasks.py18
1 files changed, 12 insertions, 6 deletions
diff --git a/rt_update_tasks.py b/rt_update_tasks.py
index d8adc5c..27a0ebd 100755
--- a/rt_update_tasks.py
+++ b/rt_update_tasks.py
@@ -30,7 +30,7 @@ def update(bugid):
header = pmig.sql_x(query, (bugid,))
if not header:
elog('no header found for %s' % (bugid,))
- return False
+ return 'missing'
def extref(ticket):
refid = phabdb.reference_ticket("%s%s" % (rtlib.prepend, ticket))
@@ -122,10 +122,16 @@ def main():
bugs = return_bug_list()
from multiprocessing import Pool
pool = Pool(processes=int(config.bz_updatemulti))
- _ = pool.map(run_update, bugs)
- complete = len(filter(bool, _))
- failed = len(_) - complete
- print '%s completed %s, failed %s' % (sys.argv[0], complete, failed)
-
+ result = pool.map(run_update, bugs)
+ missing = len([i for i in result if i == 'missing'])
+ complete = len(filter(bool, [i for i in result if i not in ['missing']]))
+ failed = (len(result) - missing) - complete
+ print '-----------------------------\n \
+ %s Total %s (missing %s)\n \
+ completed %s, failed %s' % (sys.argv[0],
+ len(bugs),
+ missing,
+ complete,
+ failed)
if __name__ == '__main__':
main()