| OLD | NEW |
| 1 #!/usr/bin/env python | 1 #!/usr/bin/env python |
| 2 # Copyright 2016 The Chromium Authors. All rights reserved. | 2 # Copyright 2016 The Chromium Authors. All rights reserved. |
| 3 # Use of this source code is governed by a BSD-style license that can be | 3 # Use of this source code is governed by a BSD-style license that can be |
| 4 # found in the LICENSE file. | 4 # found in the LICENSE file. |
| 5 | 5 |
| 6 import argparse | 6 import argparse |
| 7 import copy | 7 import copy |
| 8 import json | 8 import json |
| 9 import logging | 9 import logging |
| 10 import os | 10 import os |
| (...skipping 19 matching lines...) Expand all Loading... |
| 30 | 30 |
| 31 | 31 |
| 32 LOGGER = logging.getLogger('remote_run') | 32 LOGGER = logging.getLogger('remote_run') |
| 33 | 33 |
| 34 | 34 |
| 35 # CIPD_PINS is a mapping of master name to pinned recipe engine CIPD package | 35 # CIPD_PINS is a mapping of master name to pinned recipe engine CIPD package |
| 36 # version. If no pin is found, the CIPD pin for "None" will be used. | 36 # version. If no pin is found, the CIPD pin for "None" will be used. |
| 37 _CIPD_PINS = { | 37 _CIPD_PINS = { |
| 38 # Default recipe engine pin. | 38 # Default recipe engine pin. |
| 39 None: 'latest', | 39 None: 'latest', |
| 40 |
| 41 # Custom per-master pins. |
| 42 'chromium.infra': 'canary', |
| 40 } | 43 } |
| 41 | 44 |
| 42 | 45 |
| 43 def _call(cmd, **kwargs): | 46 def _call(cmd, **kwargs): |
| 44 LOGGER.info('Executing command: %s', cmd) | 47 LOGGER.info('Executing command: %s', cmd) |
| 45 exit_code = subprocess.call(cmd, **kwargs) | 48 exit_code = subprocess.call(cmd, **kwargs) |
| 46 LOGGER.info('Command %s finished with exit code %d.', cmd, exit_code) | 49 LOGGER.info('Command %s finished with exit code %d.', cmd, exit_code) |
| 47 return exit_code | 50 return exit_code |
| 48 | 51 |
| 49 | 52 |
| (...skipping 164 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 214 # Re-execute with the updated remote_run.py. | 217 # Re-execute with the updated remote_run.py. |
| 215 return _call([sys.executable] + argv) | 218 return _call([sys.executable] + argv) |
| 216 | 219 |
| 217 stream = annotator.StructuredAnnotationStream() | 220 stream = annotator.StructuredAnnotationStream() |
| 218 with stream.step('remote_run_result'): | 221 with stream.step('remote_run_result'): |
| 219 return main(argv) | 222 return main(argv) |
| 220 | 223 |
| 221 | 224 |
| 222 if __name__ == '__main__': | 225 if __name__ == '__main__': |
| 223 sys.exit(shell_main(sys.argv)) | 226 sys.exit(shell_main(sys.argv)) |
| OLD | NEW |