Chromium Code Reviews| OLD | NEW |
|---|---|
| (Empty) | |
| 1 # Copyright 2016 The Chromium Authors. All rights reserved. | |
| 2 # Use of this source code is governed by a BSD-style license that can be | |
| 3 # found in the LICENSE file. | |
| 4 from datetime import datetime | |
| 5 from datetime import time | |
| 6 from datetime import timedelta | |
| 7 | |
| 8 from common.base_handler import BaseHandler | |
| 9 from common.base_handler import Permission | |
| 10 from model.wf_try_job_data import WfTryJobData | |
| 11 | |
| 12 | |
| 13 # TODO(lijeffrey): Refactor formatting functions into a separate module that | |
| 14 # can be shared across Findit. | |
| 15 def _RemoveMicrosecondsFromDelta(delta): | |
| 16 """Returns a timedelta object without microseconds based on delta.""" | |
| 17 return delta - timedelta(microseconds=delta.microseconds) | |
| 18 | |
| 19 | |
| 20 def _RemoveMicrosecondsFromDatetime(date): | |
| 21 """Returns a datetime object without microseconds based on date.""" | |
| 22 if not date: | |
| 23 return None | |
| 24 | |
| 25 return datetime( | |
| 26 date.year, date.month, date.day, date.hour, date.minute, date.second) | |
| 27 | |
| 28 | |
| 29 def _FormatTimedelta(delta): | |
| 30 if not delta: | |
| 31 return None | |
| 32 hours, remainder = divmod(delta.seconds, 3600) | |
| 33 minutes, seconds = divmod(remainder, 60) | |
| 34 return '%02d:%02d:%02d' % (hours, minutes, seconds) | |
| 35 | |
| 36 | |
| 37 def _FormatDatetime(date): | |
| 38 if not date: | |
| 39 return None | |
| 40 else: | |
| 41 return _RemoveMicrosecondsFromDatetime(date).strftime( | |
| 42 '%Y-%m-%d %H:%M:%S UTC') | |
|
stgao
2016/05/04 21:13:36
no need to remove micro seconds.
lijeffrey
2016/05/04 21:43:20
Done.
| |
| 43 | |
| 44 | |
| 45 class TryJobDashboard(BaseHandler): | |
| 46 PERMISSION_LEVEL = Permission.ANYONE | |
| 47 | |
| 48 def HandleGet(self): | |
| 49 """Shows a list of Findit try job results and statuses in an HTML page.""" | |
| 50 midnight_today = datetime.combine(datetime.utcnow(), time.min) | |
| 51 midnight_yesterday = midnight_today - timedelta(days=1) | |
| 52 midnight_tomorrow = midnight_today + timedelta(days=1) | |
| 53 | |
| 54 start = self.request.get('start_date') | |
| 55 end = self.request.get('end_date') | |
| 56 start_date = (datetime.strptime(start, '%Y-%m-%d') if start else | |
| 57 midnight_yesterday) | |
| 58 end_date = (datetime.strptime(end, '%Y-%m-%d') if end else | |
| 59 midnight_tomorrow) | |
| 60 | |
| 61 if start or not end: # pragma: no cover | |
|
stgao
2016/05/04 21:13:36
Why it is no covered? Maybe "pragma: no branch" in
lijeffrey
2016/05/04 21:43:20
Done.
| |
| 62 # If a start date is specified, get everything since then. | |
| 63 try_job_query = WfTryJobData.query( | |
| 64 WfTryJobData.request_time >= start_date, | |
| 65 WfTryJobData.request_time < end_date) | |
| 66 else: # pragma: no cover | |
| 67 # If no start date specified, then get everything up until end_date. | |
| 68 start_date = None | |
| 69 try_job_query = WfTryJobData.query( | |
| 70 WfTryJobData.request_time < end_date) | |
| 71 | |
| 72 try_job_data_list = try_job_query.fetch() | |
| 73 try_jobs_in_progress = [] | |
| 74 try_jobs_with_error = [] | |
| 75 successfully_completed_try_jobs = [] | |
| 76 | |
| 77 for try_job_data in try_job_data_list: | |
| 78 try_job_display_data = { | |
| 79 'master_name': try_job_data.master_name, | |
| 80 'builder_name': try_job_data.builder_name, | |
| 81 'build_number': try_job_data.build_number, | |
| 82 'try_job_type': try_job_data.try_job_type, | |
| 83 'start_time': _FormatDatetime(try_job_data.start_time), | |
| 84 'request_time': _FormatDatetime(try_job_data.request_time), | |
| 85 'try_job_url': try_job_data.try_job_url | |
| 86 } | |
| 87 | |
| 88 if not try_job_data.end_time and not try_job_data.error: | |
| 89 try_job_display_data['elapsed_time'] = ( | |
| 90 _FormatTimedelta(datetime.utcnow() - try_job_data.request_time) if | |
| 91 try_job_data.request_time else None) | |
| 92 | |
| 93 try_job_display_data['status'] = ( | |
| 94 'running' if try_job_data.start_time else 'pending') | |
| 95 try_jobs_in_progress.append(try_job_display_data) | |
| 96 elif try_job_data.error: | |
| 97 try_job_display_data['error'] = try_job_data.error['message'] | |
| 98 # It is possible end_time is not available if the error was timeout. | |
| 99 try_job_display_data['end_time'] = _FormatDatetime( | |
| 100 try_job_data.end_time) | |
| 101 try_jobs_with_error.append(try_job_display_data) | |
| 102 else: | |
| 103 try_job_display_data['culprit_found'] = bool(try_job_data.culprits) | |
| 104 try_job_display_data['end_time'] = ( | |
| 105 _FormatDatetime(try_job_data.end_time)) | |
| 106 successfully_completed_try_jobs.append(try_job_display_data) | |
| 107 | |
| 108 data = { | |
| 109 'start_date': _FormatDatetime(start_date), | |
| 110 'end_date': _FormatDatetime(end_date), | |
| 111 'try_jobs_in_progress': try_jobs_in_progress, | |
| 112 'try_jobs_with_error': try_jobs_with_error, | |
| 113 'successfully_completed_try_jobs': successfully_completed_try_jobs | |
| 114 } | |
| 115 | |
| 116 return { | |
| 117 'template': 'try_job_dashboard.html', | |
| 118 'data': data | |
| 119 } | |
| OLD | NEW |