def METHOD_NAME(kfp_client, experiment_id):
    test_file_dir = "resources/config/ack-hosting"
    download_dir = utils.mkdir(os.path.join(test_file_dir + "/generated"))
    test_params = utils.load_params(
        utils.replace_placeholders(
            os.path.join(test_file_dir, "config.yaml"),
            os.path.join(download_dir, "config.yaml"),
        )
    )
    input_model_name = utils.generate_random_string(10) + "-v2-model"
    input_endpoint_config_name = (
        utils.generate_random_string(10) + "-v2-endpoint-config"
    )
    input_endpoint_name = utils.generate_random_string(10) + "-v2-endpoint"
    test_params["Arguments"]["model_name"] = input_model_name
    test_params["Arguments"]["endpoint_config_name"] = input_endpoint_config_name
    test_params["Arguments"]["endpoint_name"] = input_endpoint_name
    test_params["Arguments"]["production_variants"][0]["modelName"] = input_model_name
    try:
        run_id, _, _ = kfp_client_utils.compile_run_monitor_pipeline(
            kfp_client,
            experiment_id,
            test_params["PipelineDefinition"],
            test_params["Arguments"],
            download_dir,
            test_params["TestName"],
            60,
            "running",
        )
        assert ack_utils.wait_for_condition(
            input_endpoint_name,
            ack_utils.does_endpoint_exist,
            wait_periods=12,
            period_length=12,
        )
        kfp_client_utils.terminate_run(kfp_client, run_id)
        assert ack_utils.wait_for_condition(
            input_endpoint_name,
            ack_utils.is_endpoint_deleted,
            wait_periods=20,
            period_length=20,
        )
    finally:
        ack_utils._delete_resource(
            input_endpoint_config_name, "endpointconfigs"
        )
        ack_utils._delete_resource(input_model_name, "models")