e47f6345f10568dd43b8d28c096870a03e70b7b3,google/datalab/contrib/bigquery/commands/_bigquery.py,,_get_execute_parameters,#Any#Any#Any#Any#Any#,175

Before Change

      if "mode" in bq_pipeline_output_config:
          execute_task_config["mode"] = bq_pipeline_output_config["mode"]

    execute_task_config["parameters"] = []
    if bq_pipeline_parameters_config:
      execute_task_config["parameters"].extend(bq_pipeline_parameters_config)
    // We merge the parameters with the airflow macros so that users can specify airflow macro
    // names (like "@ds") in sql
    airflow_macros_list = [{"name": key, "type": "STRING", "value": value}
                           for key, value in Pipeline.airflow_macros.items()]
    execute_task_config["parameters"].extend(airflow_macros_list)

    return execute_task_config

After Change

      // name conflicts.
      merged_query_parameters.update(user_defined_query_parameters)

    execute_task_config["parameters"] = [
      {"name": name, "type": type, "value": value}
      for name, (value, type) in merged_query_parameters.items()
    ]

    if bq_pipeline_output_config:
      if "table" in bq_pipeline_output_config:
        execute_task_config["table"] = bq_pipeline_output_config["table"]

Instances