diff options
author | cpettet <rush@wikimedia.org> | 2014-12-16 16:03:11 -0600 |
---|---|---|
committer | cpettet <rush@wikimedia.org> | 2014-12-16 16:03:11 -0600 |
commit | 39d05f179c749aa14cdf9c7fc5e0c95efb5a29da (patch) | |
tree | 633b5e4a6c255a7a668ac7e11a7ebffad7d32065 /rt_update_tasks.py | |
parent | a339253851065809235d3b1dcd9e6eb315e58152 (diff) |
rt cleanup and user updates for header and comments
Diffstat (limited to 'rt_update_tasks.py')
-rwxr-xr-x | rt_update_tasks.py | 18 |
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() |