Skip to content

Instantly share code, notes, and snippets.

@tuanchris
Created May 23, 2020 03:36
Show Gist options
  • Save tuanchris/f7c7f866400f737d01637d2663adfbaf to your computer and use it in GitHub Desktop.
Save tuanchris/f7c7f866400f737d01637d2663adfbaf to your computer and use it in GitHub Desktop.
project_id = 'cloud-data-lake'
staging_dataset = 'IMMIGRATION_DWH_STAGING'
dwh_dataset = 'IMMIGRATION_DWH'
gs_bucket = 'cloud-data-lake-gcp'
dag = DAG('cloud-data-lake-pipeline',
start_date=datetime.now(),
schedule_interval='@once',
concurrency=5,
max_active_runs=1,
default_args=default_args)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment