def METHOD_NAME() -> None:
    importlib.reload(cluster)
    with patch.object(ClickhousePool, "execute") as execute:
        execute.return_value = ClickhouseResult(
            [("host_1", 9000, 1, 1), ("host_2", 9000, 2, 1)]
        )
        local_cluster = get_storage(StorageKey("errors")).get_cluster()
        assert len(local_cluster.get_local_nodes()) == 1
        assert local_cluster.get_local_nodes()[0].host_name == "host_1"
        assert local_cluster.get_local_nodes()[0].port == 9000
        assert local_cluster.get_local_nodes()[0].shard is None
        assert local_cluster.get_local_nodes()[0].replica is None
        distributed_cluster = get_storage(StorageKey("transactions")).get_cluster()
        assert len(distributed_cluster.get_local_nodes()) == 2
        assert distributed_cluster.get_local_nodes()[0].host_name == "host_1"
        assert distributed_cluster.get_local_nodes()[1].host_name == "host_2"