def _write_to_bq()

in pipelines/cdp/cdp_pipeline/customer_data_platform.py [0:0]

• 11 lines of code
• 1 McCabe index (conditional complexity)

def _write_to_bq(unified_pcoll: PCollection, project_id: str,
                 output_dataset: str, output_table: str, unified_schema: str):
  unified_pcoll | "Write to bigquery" >> \
  WriteToBigQuery(
          project=project_id,
          dataset=output_dataset,
          table=output_table,
          schema=unified_schema,
          create_disposition=beam.io.BigQueryDisposition.CREATE_IF_NEEDED,
          write_disposition=beam.io.BigQueryDisposition.WRITE_APPEND
      )