function create_dataform_udaf_test_view()

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`)}`
      );
}