def bigquery_xcom_query()

in utils/gcp.py [0:0]

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

def bigquery_xcom_query(
    destination_table,
    dataset_id,
    xcom_task_id,
    parameters=(),
    arguments=(),
    project_id=None,
    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",
    table_partition_template="${{ds_nodash}}",
    **kwargs,