def bigquery_etl_query()

in utils/gcp.py [0:0]

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

def bigquery_etl_query(
    destination_table,
    dataset_id,
    parameters=(),
    arguments=(),
    project_id=None,
    sql_file_path=None,
    reattach_on_restart=True,
    gcp_conn_id="google_cloud_airflow_gke",
    gke_project_id=GCP_PROJECT_ID,
    gke_location="us-west1",
    gke_cluster_name="workloads-prod-v1",
    gke_namespace="default",
    docker_image=BIGQUERY_ETL_DOCKER_IMAGE,
    date_partition_parameter="submission_date",
    multipart=False,
    is_delete_operator_pod=False,
    table_partition_template="${{ds_nodash}}",
    **kwargs,