Skip to content

Instantly share code, notes, and snippets.

@alexvanboxel

alexvanboxel/medium_agc1_bq1.py

Last active December 27, 2016 20:50
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save alexvanboxel/c8dc5084833a4fc49d1c0dd798eaa684 to your computer and use it in GitHub Desktop.
Save alexvanboxel/c8dc5084833a4fc49d1c0dd798eaa684 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
medium_agc1_bq1.py
with DAG('gcp_smoke_bq', schedule_interval=timedelta(days=1),
default_args=default_args) as dag:
bq_extract_one_day = BigQueryOperator(
task_id='bq_extract_one_day',
bql='gcp_smoke/gsob_extract_day.sql',
destination_dataset_table=
'airflow.gsod_partition{{ ds_nodash }}',
write_disposition='WRITE_TRUNCATE',
bigquery_conn_id='gcp_smoke',
use_legacy_sql=False
)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment