Source code for asv.commands.setup

# Licensed under a 3-clause BSD style license - see LICENSE.rst

import logging
import traceback
from collections import defaultdict

from .. import environment, util
from ..console import log
from . import Command, common_args




def _create(env):
    with log.set_level(logging.WARNING):
        env.create()





def _create_parallel(envs):
    try:
        for env in envs:
            _create(env)
    except BaseException as exc:
        raise util.ParallelFailure(str(exc), exc.__class__, traceback.format_exc())





class Setup(Command):
    @classmethod


    def setup_arguments(cls, subparsers):
        parser = subparsers.add_parser(
            "setup",
            help="Setup virtual environments",
            description="""Setup virtual environments for each
            combination of Python version and third-party requirement.
            This is called by the ``run`` command implicitly, and
            isn't generally required to be run on its own.""",
        )

        common_args.add_parallel(parser)

        common_args.add_environment(parser)

        parser.set_defaults(func=cls.run_from_args)

        return parser


    @classmethod


    def run_from_conf_args(cls, conf, args):
        return cls.run(conf=conf, parallel=args.parallel, env_spec=args.env_spec)


    @classmethod


    def run(cls, conf, parallel=-1, env_spec=None):
        environments = list(environment.get_environments(conf, env_spec))
        cls.perform_setup(environments, parallel=parallel)
        return environments


    @classmethod


    def perform_setup(cls, environments, parallel=-1):
        if environment.is_existing_only(environments):
            # Nothing to do, so don't print anything
            return environments

        parallel, multiprocessing = util.get_multiprocessing(parallel)

        log.info("Creating environments")
        with log.indent():
            if parallel != 1:
                try:
                    # Run creation in parallel only for environments with
                    # different dir_names
                    environment_groups = defaultdict(list)
                    for env in environments:
                        environment_groups[env.dir_name].append(env)

                    pool = util.get_multiprocessing_pool(parallel)
                    try:
                        pool.map(_create_parallel, environment_groups.values())
                        pool.close()
                        pool.join()
                    finally:
                        pool.terminate()
                except util.ParallelFailure as exc:
                    exc.reraise()
            else:
                list(map(_create, environments))