def METHOD_NAME(consumer_group, expected):
    function: mlrun.runtimes.RemoteRuntime = mlrun.new_function("tst", kind="nuclio")
    with expected:
        function.add_v3io_stream_trigger(
            "v3io:///projects/x/y",
            name="mystream",
            group=consumer_group,
            access_key="x",
        )
        trigger = function.spec.config["spec.triggers.mystream"]
        assert trigger["attributes"]["consumerGroup"] == consumer_group