| OLD | NEW |
| 1 # Copyright 2014 The Chromium Authors. All rights reserved. | 1 # Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 # Use of this source code is governed by a BSD-style license that can be | 2 # Use of this source code is governed by a BSD-style license that can be |
| 3 # found in the LICENSE file. | 3 # found in the LICENSE file. |
| 4 | 4 |
| 5 import datetime | 5 import datetime |
| 6 import functools | 6 import functools |
| 7 | 7 |
| 8 from recipe_engine.types import freeze | 8 from recipe_engine.types import freeze |
| 9 from recipe_engine import recipe_api | 9 from recipe_engine import recipe_api |
| 10 | 10 |
| (...skipping 619 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 630 except (KeyError, AttributeError): # pragma: no cover | 630 except (KeyError, AttributeError): # pragma: no cover |
| 631 # No isolated_out data exists (or any JSON at all) | 631 # No isolated_out data exists (or any JSON at all) |
| 632 pass | 632 pass |
| 633 | 633 |
| 634 def _gtest_collect_step(self, merged_test_output, task, **kwargs): | 634 def _gtest_collect_step(self, merged_test_output, task, **kwargs): |
| 635 """Produces a step that collects and processes a result of gtest task.""" | 635 """Produces a step that collects and processes a result of gtest task.""" |
| 636 args = [ | 636 args = [ |
| 637 'python', | 637 'python', |
| 638 self.resource('collect_gtest_task.py'), | 638 self.resource('collect_gtest_task.py'), |
| 639 '--swarming-client-dir', self.m.swarming_client.path, | 639 '--swarming-client-dir', self.m.swarming_client.path, |
| 640 '--temp-root-dir', self.m.path['tmp'], | 640 '--temp-root-dir', self.m.path['tmp_base'], |
| 641 ] | 641 ] |
| 642 | 642 |
| 643 # Where to put combined summary to, consumed by recipes. Also emit | 643 # Where to put combined summary to, consumed by recipes. Also emit |
| 644 # test expectation only if |merged_test_output| is really used. | 644 # test expectation only if |merged_test_output| is really used. |
| 645 step_test_data = kwargs.pop('step_test_data', None) | 645 step_test_data = kwargs.pop('step_test_data', None) |
| 646 if merged_test_output: | 646 if merged_test_output: |
| 647 args.extend(['--merged-test-output', merged_test_output]) | 647 args.extend(['--merged-test-output', merged_test_output]) |
| 648 if not step_test_data: | 648 if not step_test_data: |
| 649 sample_swarming_summary = { | 649 sample_swarming_summary = { |
| 650 'swarming_summary': { | 650 'swarming_summary': { |
| (...skipping 277 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 928 | 928 |
| 929 def get_shard_view_url(self, index): | 929 def get_shard_view_url(self, index): |
| 930 """Returns URL of HTML page with shard details or None if not available. | 930 """Returns URL of HTML page with shard details or None if not available. |
| 931 | 931 |
| 932 Works only after the task has been successfully triggered. | 932 Works only after the task has been successfully triggered. |
| 933 """ | 933 """ |
| 934 if self._trigger_output and self._trigger_output.get('tasks'): | 934 if self._trigger_output and self._trigger_output.get('tasks'): |
| 935 for shard_dict in self._trigger_output['tasks'].itervalues(): | 935 for shard_dict in self._trigger_output['tasks'].itervalues(): |
| 936 if shard_dict['shard_index'] == index: | 936 if shard_dict['shard_index'] == index: |
| 937 return shard_dict['view_url'] | 937 return shard_dict['view_url'] |
| OLD | NEW |