1c6c1a34727c620a6d419b9cfb67637371f79617,tests/integration_tests/test_cli.py,,_run_ludwig,#Any#,31

Before Change

def _run_ludwig(command, **ludwig_kwargs):
    commands = ["ludwig", command]
    for arg_name, value in ludwig_kwargs.items():
        commands += ["--" + arg_name, value]
    cmdline = " ".join(commands)
    print(cmdline)
    completed_process = subprocess.run(cmdline, shell=True, encoding="utf-8",
                                       stdout=subprocess.PIPE,
                                       env=os.environ.copy())
    assert completed_process.returncode == 0

    return completed_process


def _prepare_data(csv_filename, config_filename):
    // Single sequence input, single category output

After Change

def _run_ludwig(command, **ludwig_kwargs):
    commands = ["ludwig", command]
    return _run_commands(commands, **ludwig_kwargs)


def _run_ludwig_horovod(command, **ludwig_kwargs):
    commands = ["horovodrun", "-np", "2", "ludwig", command]

Instances