def METHOD_NAME(runner: CollectingQueryRunner, nc_model: NCModel, G: Graph) -> None:
    nc_model.predict_stream_estimate(G)
    assert (
        runner.last_query() == "CALL gds.beta.pipeline.nodeClassification.predict.stream.estimate($graph_name, $config)"
    )
    assert runner.last_params() == {
        "graph_name": G.name(),
        "config": {"modelName": nc_model.name()},
    }