in utils/gcp.py [0:0]
def export_to_parquet(
table,
destination_table=None,
static_partitions=None,
arguments=None,
use_storage_api=False,
dag_name="export_to_parquet",
parent_dag_name=None,
default_args=None,
gcp_conn_id="google_cloud_airflow_dataproc",
dataproc_storage_bucket="airflow-dataproc-bq-parquet-exports",
num_workers=2,
num_preemptible_workers=0,
gcs_output_bucket="airflow-dataproc-bq-parquet-exports",
region="us-west1",