Class ProcessInvoker

src/utils/process_utils.py:14–43

class ProcessInvoker:

    def __init__(self, env_vars: EnvVariables):
        super().__init__()
        self._env_vars = env_vars

    def invoke(self, command, work_dir='.', *, environment_variables: dict = None, check_stderr=True, shell=False):
        if isinstance(command, str) and not shell:
            command = split_command(command, working_directory=work_dir)

        env_vars = self._env_vars.build_env_vars(environment_variables)

        p = subprocess.Popen(command,
                             stdout=subprocess.PIPE,
                             stderr=subprocess.PIPE,
                             cwd=work_dir,
                             env=env_vars,
                             universal_newlines=True,
                             shell=shell)

        (output, error) = p.communicate()

        result_code = p.returncode
        if result_code != 0:
            raise ExecutionException(result_code, error, output)

        if error and check_stderr:
            LOGGER.warning("Error output wasn't empty, although the command finished with code 0!")

        return output


def split_command(script_command, working_directory=None):