025b3007100305409f3b3bdeff1741f46b5d31de,google/datalab/contrib/bigquery/commands/_bigquery.py,,_get_load_parameters,#,97

Before Change

      // gcs->table (or load) step, so we take that as the input table (and emit a load
      // operator).
      source_of_table = bq_pipeline_output_config
      load_task_config["table"] = source_of_table.get("table")

    // If a table or path are absent, there is no load to be done so we return None
    if load_task_config["table"] is None or load_task_config["path"] is None:
      return None

After Change

    load_task_config = {"type": "pydatalab.bq.load"}

    // The path URL of the GCS load file(s).
    if "path" not in bq_pipeline_input_config:
      return None

    // The path URL of the GCS load file(s), and associated parameters
    load_task_config["path"] = bq_pipeline_input_config.get("path")

    if "format" in bq_pipeline_input_config:
      load_task_config["format"] = bq_pipeline_input_config["format"]

Instances