OLD | NEW |
1 #!/usr/bin/env python | 1 #!/usr/bin/env python |
2 # Copyright 2015 The LUCI Authors. All rights reserved. | 2 # Copyright 2015 The LUCI Authors. All rights reserved. |
3 # Use of this source code is governed under the Apache License, Version 2.0 | 3 # Use of this source code is governed under the Apache License, Version 2.0 |
4 # that can be found in the LICENSE file. | 4 # that can be found in the LICENSE file. |
5 | 5 |
6 """Tool to interact with recipe repositories. | 6 """Tool to interact with recipe repositories. |
7 | 7 |
8 This tool operates on the nearest ancestor directory containing an | 8 This tool operates on the nearest ancestor directory containing an |
9 infra/config/recipes.cfg. | 9 infra/config/recipes.cfg. |
10 """ | 10 """ |
(...skipping 155 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
166 sys.stdout, | 166 sys.stdout, |
167 emit_timestamps=(args.timestamps or | 167 emit_timestamps=(args.timestamps or |
168 op_args.annotation_flags.emit_timestamp), | 168 op_args.annotation_flags.emit_timestamp), |
169 ) | 169 ) |
170 | 170 |
171 if op_args.logdog.streamserver_uri: | 171 if op_args.logdog.streamserver_uri: |
172 logging.debug('Using LogDog with parameters [%v]', op_args.logdog) | 172 logging.debug('Using LogDog with parameters [%v]', op_args.logdog) |
173 stream_engine.append_stream_engine(stream_logdog.StreamEngine( | 173 stream_engine.append_stream_engine(stream_logdog.StreamEngine( |
174 streamserver_uri=op_args.logdog.streamserver_uri, | 174 streamserver_uri=op_args.logdog.streamserver_uri, |
175 name_base=(op_args.logdog.name_base or None), | 175 name_base=(op_args.logdog.name_base or None), |
| 176 dump_path=op_args.logdog.final_annotation_dump_path, |
176 )) | 177 )) |
177 | 178 |
178 # If we're teeing, also fold in a standard annotation stream engine. | 179 # If we're teeing, also fold in a standard annotation stream engine. |
179 if op_args.logdog.tee: | 180 if op_args.logdog.tee: |
180 stream_engine.append_stream_engine(build_annotation_stream_engine()) | 181 stream_engine.append_stream_engine(build_annotation_stream_engine()) |
181 else: | 182 else: |
182 # Not using LogDog; use a standard annotation stream engine. | 183 # Not using LogDog; use a standard annotation stream engine. |
183 stream_engine.append_stream_engine(build_annotation_stream_engine()) | 184 stream_engine.append_stream_engine(build_annotation_stream_engine()) |
184 | 185 |
185 with stream_engine: | 186 with stream_engine: |
(...skipping 413 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
599 | 600 |
600 if not isinstance(ret, int): | 601 if not isinstance(ret, int): |
601 if ret is None: | 602 if ret is None: |
602 ret = 0 | 603 ret = 0 |
603 else: | 604 else: |
604 print >> sys.stderr, ret | 605 print >> sys.stderr, ret |
605 ret = 1 | 606 ret = 1 |
606 sys.stdout.flush() | 607 sys.stdout.flush() |
607 sys.stderr.flush() | 608 sys.stderr.flush() |
608 os._exit(ret) | 609 os._exit(ret) |
OLD | NEW |