| OLD | NEW |
| 1 # Copyright 2016 The LUCI Authors. All rights reserved. | 1 # Copyright 2016 The LUCI Authors. All rights reserved. |
| 2 # Use of this source code is governed under the Apache License, Version 2.0 | 2 # Use of this source code is governed under the Apache License, Version 2.0 |
| 3 # that can be found in the LICENSE file. | 3 # that can be found in the LICENSE file. |
| 4 | 4 |
| 5 from __future__ import print_function | 5 from __future__ import print_function |
| 6 | 6 |
| 7 import contextlib | 7 import contextlib |
| 8 import logging | 8 import logging |
| 9 import os | 9 import os |
| 10 import shutil | 10 import shutil |
| 11 import subprocess | 11 import subprocess |
| 12 import sys | 12 import sys |
| 13 import tempfile | 13 import tempfile |
| 14 | 14 |
| 15 from recipe_engine import fetch | 15 from recipe_engine import fetch |
| 16 from recipe_engine import package | 16 from recipe_engine import package |
| 17 | 17 |
| 18 | 18 |
| 19 @contextlib.contextmanager | 19 @contextlib.contextmanager |
| 20 def ensure_workdir(args): | 20 def ensure_workdir(args): |
| 21 workdir_tempdir = False | 21 workdir_tempdir = False |
| 22 if not args.workdir: | 22 if not args.workdir: |
| 23 workdir_tempdir = True | 23 workdir_tempdir = True |
| 24 args.workdir = tempfile.mkdtemp(prefix='recipe_engine_remote_run_') | 24 args.workdir = tempfile.mkdtemp(prefix='recipe_engine_remote_') |
| 25 logging.info('Created temporary workdir %s', args.workdir) | 25 logging.info('Created temporary workdir %s', args.workdir) |
| 26 | 26 |
| 27 try: | 27 try: |
| 28 yield | 28 yield |
| 29 finally: | 29 finally: |
| 30 if workdir_tempdir: | 30 if workdir_tempdir: |
| 31 shutil.rmtree(args.workdir, ignore_errors=True) | 31 shutil.rmtree(args.workdir, ignore_errors=True) |
| 32 | 32 |
| 33 | 33 |
| 34 def main(args): | 34 def main(args): |
| 35 with ensure_workdir(args): | 35 with ensure_workdir(args): |
| 36 checkout_dir = os.path.join(args.workdir, 'checkout') | 36 checkout_dir = os.path.join(args.workdir, 'checkout') |
| 37 if args.use_gitiles: | 37 if args.use_gitiles: |
| 38 args.revision = args.revision or 'HEAD' | 38 args.revision = args.revision or 'HEAD' |
| 39 backend = fetch.GitilesBackend() | 39 backend = fetch.GitilesBackend() |
| 40 else: | 40 else: |
| 41 args.revision = args.revision or 'FETCH_HEAD' | 41 args.revision = args.revision or 'FETCH_HEAD' |
| 42 backend = fetch.GitBackend() | 42 backend = fetch.GitBackend() |
| 43 backend.checkout( | 43 backend.checkout( |
| 44 args.repository, args.revision, checkout_dir, allow_fetch=True) | 44 args.repository, args.revision, checkout_dir, allow_fetch=True) |
| 45 recipes_cfg = package.ProtoFile( | 45 recipes_cfg = package.ProtoFile( |
| 46 package.InfraRepoConfig().to_recipes_cfg(checkout_dir)) | 46 package.InfraRepoConfig().to_recipes_cfg(checkout_dir)) |
| 47 cmd = [ | 47 cmd = [ |
| 48 sys.executable, | 48 sys.executable, |
| 49 os.path.join( | 49 os.path.join( |
| 50 checkout_dir, | 50 checkout_dir, |
| 51 recipes_cfg.read().recipes_path, | 51 recipes_cfg.read().recipes_path, |
| 52 'recipes.py'), | 52 'recipes.py'), |
| 53 'run' | 53 ] + args.remote_args |
| 54 ] + args.run_args | |
| 55 logging.info('Running %r', cmd) | 54 logging.info('Running %r', cmd) |
| 56 return subprocess.call(cmd) | 55 return subprocess.call(cmd) |
| OLD | NEW |