in cicd/unit_test_utils.js [58:76]
function create_dataform_udaf_test_view(test_name, udf_name, test_case) {
let udf_input_aliases = [];
test_case.input_columns.forEach((input, index) => {
if (input.includes(' NOT AGGREGATE')) {
udf_input_aliases.push(`${input.split(' NOT AGGREGATE')[0]}`);
} else {
udf_input_aliases.push(`test_input_${index}`);
}
});
udf_input_aliases = udf_input_aliases.join(',');
const udf_invocation_str = `${get_udf_project_and_dataset(udf_name)}${udf_name}(${udf_input_aliases})`;
publish(`${test_name}_dummy_view`).type("view").query("SELECT 1 as col1");
publish(test_name)
.type("view")
.query(
(ctx) => `SELECT ${udf_invocation_str} AS udf_output\n` +
`FROM ${ctx.resolve(`${test_name}_dummy_view`)}`
);
}