b7434a326b7d5734ba504727d26706743673ccaf,mltsp/tests/test_parallel_processing.py,,test_featurize_prediction_data_in_parallel,#,49

Before Change

def test_featurize_prediction_data_in_parallel():
    Test parallel featurization of prediction TS data
    // Check if Disco is running
    try:
        process = Popen(["disco", "status"], stdout=PIPE, stderr=PIPE)
        stdout, stderr = process.communicate()
        disco_running = "running" in stdout
    except OSError:
        disco_running = False
    if not disco_running:
        print("Disco not running - aborting test.")
        return
    generate_model()

After Change

def test_featurize_prediction_data_in_parallel():
    Test parallel featurization of prediction TS data
    disco_running = util.check_disco_running()
    if not disco_running:
        print("Disco not running - aborting test.")
        return
    generate_model()

Instances