d61cbc3fc1ef837677c5402b564a30671c9e140f,tests/integration_tests/flows/common.py,,stop_mindsdb,#Any#,187

Before Change

    sp = subprocess.Popen("kill -9 $(lsof -t -i:47335)", shell=True)
    sp.wait()
    sp = subprocess.Popen("kill -9 $(lsof -t -i:47336)", shell=True)
    sp.wait()


def run_environment(config, apis=["mysql"], override_integration_config={}, override_api_config={}, mindsdb_database="mindsdb", clear_storage=True):
    temp_config_path = prepare_config(config, mindsdb_database, override_integration_config, override_api_config, clear_storage)

After Change

    if sp:
        sp.kill()
    conns = net_connections()
    pids = [x.pid for x in conns
            if x.pid is not None and x.status == "LISTEN"
            and x.laddr[1] in (47334, 47335, 47336)]

    for pid in pids:
        try:
            os.kill(pid, 9)
        // process may be killed by OS due to some reasons in that moment
        except ProcessLookupError:
            pass
    // sp = subprocess.Popen("kill -9 $(lsof -t -i:47334)", shell=True)
    // sp.wait()
    // sp = subprocess.Popen("kill -9 $(lsof -t -i:47335)", shell=True)
    // sp.wait()
    // sp = subprocess.Popen("kill -9 $(lsof -t -i:47336)", shell=True)
    // sp.wait()


def run_environment(config, apis=["mysql"], override_integration_config={}, override_api_config={}, mindsdb_database="mindsdb", clear_storage=True):
    temp_config_path = prepare_config(config, mindsdb_database, override_integration_config, override_api_config, clear_storage)
    config = Config(temp_config_path)

Instances