b351d1394087251b119930bf4aaee7a79ef4e55a,python/ray/tests/test_reconstruction.py,,test_reconstruction_cached_dependency,#Any#Any#,53

Before Change

@pytest.mark.parametrize("reconstruction_enabled", [False, True])
def test_reconstruction_cached_dependency(ray_start_cluster,
                                          reconstruction_enabled):
    config = json.dumps({
        "num_heartbeats_timeout": 10,
        "raylet_heartbeat_timeout_milliseconds": 100,
        "lineage_pinning_enabled": 1 if reconstruction_enabled else 0,
        "free_objects_period_milliseconds": -1,
        "initial_reconstruction_timeout_milliseconds": 200,
    })
    cluster = ray_start_cluster
    // Head node with no resources.
    cluster.add_node(num_cpus=0, _internal_config=config)
    ray.init(address=cluster.address)

After Change

@pytest.mark.parametrize("reconstruction_enabled", [False, True])
def test_reconstruction_cached_dependency(ray_start_cluster,
                                          reconstruction_enabled):
    config = {
        "num_heartbeats_timeout": 10,
        "raylet_heartbeat_timeout_milliseconds": 100,
        "initial_reconstruction_timeout_milliseconds": 200,
    }
    // Workaround to reset the config to the default value.
    if not reconstruction_enabled:
        config["lineage_pinning_enabled"] = 0
    config = json.dumps(config)

    cluster = ray_start_cluster
    // Head node with no resources.
    cluster.add_node(

Instances